Struct FrameStreamEncoder 

pub struct FrameStreamEncoder<F>
where
    F: FnMut(&[u8]),
{ /* private fields */ }

Encodes a stream of bytes into framed messages.

Each frame is emitted with proper metadata. Frames are emitted when enough data is buffered or when explicitly flushed. Optionally, a callback can be registered to observe each encoded frame.

Implementations

impl<F> FrameStreamEncoder<F>

where F: FnMut(&[u8]),

pub fn new( stream_id: u32, max_chunk_size: usize, on_emit: F, ) -> FrameStreamEncoder<F>

Creates a new encoder with the given stream ID and payload limit.

An optional on_emit callback will be invoked with every emitted frame (as raw encoded bytes).

pub fn write_bytes(&mut self, data: &[u8]) -> Result<usize, FrameEncodeError>

Accepts some bytes, returns zero or more encoded frames (ready to send). Buffers any leftover partial chunk internally.

pub fn flush(&mut self) -> Result<usize, FrameEncodeError>

Flushes remaining buffered data as a final frame (could be partial).

pub fn end_stream(&mut self) -> Result<usize, FrameEncodeError>

Returns an End frame, even if no data was ever sent.

pub fn cancel_stream(&mut self) -> Result<usize, FrameEncodeError>

Emits a Cancel frame for this stream.