SendableFrameStream

Type Alias SendableFrameStream 

Source
pub type SendableFrameStream = Pin<Box<dyn Stream<Item = Result<Frame, StreamError>> + Send>>;
Expand description

Primary result type for async query execution.

A sendable stream of query result frames. This is the async equivalent of DataFusion’s SendableRecordBatchStream, but uses Frame as the data unit instead of RecordBatch.

The stream is bounded for backpressure - producers will wait if consumers are slow.

Aliased Type§

pub struct SendableFrameStream { /* private fields */ }