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 */);