createRequestStream method

StreamController<Q> createRequestStream(
  1. StreamSubscription incoming
)

Implementation

StreamController<Q> createRequestStream(StreamSubscription incoming) =>
    StreamController<Q>(
      onListen: incoming.resume,
      onPause: incoming.pause,
      onResume: incoming.resume,
    );