BufferedStream<T> constructor

BufferedStream<T>()

Implementation

BufferedStream() {
  _stream = _controller.stream.asBroadcastStream(onListen: (sub) async {
    _subCount++;
    _push();
  }, onCancel: (sub) {
    _subCount--;
  });
}