Skip to main content

RowBatchStream

Type Alias RowBatchStream 

Source
pub type RowBatchStream = Box<dyn Stream<Item = PeekResponseUnary> + Unpin + Send + Sync>;
Expand description

A stream of batched rows delivered to a client writer.

This is a boxed stream, not a bare channel receiver, so the coordinator can insert an adapter between itself and the client writer. The SUBSCRIBE path wraps the receiver in a byte-accounting map whose closure type cannot be named, so it has to be boxed. Consumers box the receiver into a RecordFirstRowStream regardless, so this adds no allocation.

Aliased Typeยง

pub struct RowBatchStream(/* private fields */);