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