stream property

Stream<ParsedRowBuffer> get stream

Stream of parsed row buffers.

Listen to this stream to receive query result chunks. When maxBufferSize is set, backpressure is applied to producers that call addChunk.

Implementation

Stream<ParsedRowBuffer> get stream => Stream<ParsedRowBuffer>.multi(
      (listener) {
        final subscription = _controller.stream.listen(
          (chunk) {
            _onDelivered();
            listener.add(chunk);
          },
          onError: listener.addError,
          onDone: listener.close,
        );
        listener
          ..onPause = subscription.pause
          ..onResume = subscription.resume
          ..onCancel = subscription.cancel;
      },
    );