PausableStream<T> constructor

PausableStream<T>(Stream<T> _source)

Creates a PausableStream that wraps the _source stream.

Implementation

PausableStream(this._source) {
  _controller = StreamController<T>(
    onListen: _start,
    onPause: pause,
    onResume: resume,
    onCancel: _cancel,
  );
}