Struct BatchFrameStream 

pub struct BatchFrameStream<S> { /* private fields */ }

Batch frame stream for improved throughput.

Implementations

impl<S> BatchFrameStream<S>

where S: Stream<Item = Frame> + Unpin + Send + 'static,

pub fn new(stream: S, format: StreamFormat, batch_size: usize) -> Self

Wrap a frame stream and emit batches of up to batch_size frames.

pub fn content_type(&self) -> &'static str

Returns the Content-Type that accurately describes what this stream emits.

BatchFrameStream serializes each batch as newline-delimited JSON objects, so StreamFormat::Json is promoted to application/x-ndjson — the output is not a single well-formed JSON document and must not be advertised as one.

pub fn into_stream( self, ) -> impl Stream<Item = Result<Vec<u8>, StreamTransportError>> + Send + 'static

Consume the builder and return a Stream of formatted batch payloads.

Each item is one full batch as Vec<u8>. For StreamFormat::Json and StreamFormat::NdJson the bytes hold one JSON object per frame, one per line (NDJSON-of-objects, #167). The stream item type is binary (Vec<u8>, not String) to leave room for future per-batch compression (#226).