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;
    }
    ..onResume = () {
      _isPaused = false;
    };
}