pub type ReduceStream = BoxStream<'static, Result<StreamMessage<ReduceResponse>, ClientError>>;Expand description
Final reduction results, delivered in bounded frames without collecting all groups.
Each item retains its wire buffer and exposes a borrowed response through view().
Dropping the stream cancels the request. Only opening the stream and receiving
its first frame may be retried. Errors after that frame are returned to the caller.
Aliased Typeยง
#[repr(transparent)]pub struct ReduceStream { /* private fields */ }