StreamingQuery constructor

StreamingQuery({
  1. int? maxBufferSize,
})

Creates a new StreamingQuery instance.

maxBufferSize caps how many chunks can be buffered before the producer is blocked. Null means unbounded.

Implementation

StreamingQuery({this.maxBufferSize})
    : _controller = StreamController<ParsedRowBuffer>(
        onPause: () {},
        onResume: () {},
      ) {
  _controller.onPause = () => _isPaused = true;
  _controller.onResume = () => _isPaused = false;
  _outputStream = _controller.stream.map(_onDeliver);
}