subscribeNonBatch<T> method

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

Implementation

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

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

  return controller.stream;
}