subscribe<T> method

Future<Stream<T>> subscribe<T>(
  1. String methodPrefix, [
  2. List params = const []
])

Implementation

Future<Stream<T>> subscribe<T>(String methodPrefix,
    [List params = const []]) async {
  var subscribable = _subscribables[methodPrefix];
  if (subscribable == null) {
    throw RpcException.methodNotFound(methodPrefix);
  }

  var controller = makeSubscription<T>(subscribable, params);
  await request(subscribable.methodSubscribe, params).then((result) {
    controller.sink.add(result);
  });

  return controller.stream;
}