Module stream 

Structs

StreamDecoder

A low-level interface for reading [RecordBatch] data from a stream of bytes

Enums

DecoderState 🔒

Functions

reserve_declared 🔒

Reserves a message’s declared length before copying its first bytes into an empty buf, bounded as in read_body_bounded. Growing with each input buffer instead doubles the capacity, and the decoded batch, which is zero-copy over buf, keeps up to twice its size.