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);