Struct LengthPrefixedFrame 

pub struct LengthPrefixedFrame { /* private fields */ }

Decodes arbitrary fragmented or coalesced HTTP/2 DATA payloads.

Length limits are checked before allocating a message body. A failed decoder rejects further input until reset. An error from push discards any messages completed in that call; callers must terminate the affected RPC stream.

Implementations

impl LengthPrefixedFrame

pub fn new(max_message_size: usize) -> Self

Creates a decoder with a maximum encoded payload length in bytes.

pub fn push(&mut self, chunk: &[u8]) -> Result<Vec<AlignedMessageBuf>, Status>

Consumes one DATA chunk and returns every complete message in wire order.

Empty chunks are valid. Partial headers and bodies remain buffered until the next call. Compression negotiation and decompression belong to the caller.

Errors

Returns internal for an invalid compressed flag, resource exhausted for oversized messages or allocation failure, or the previous decoder failure.

pub fn finish(&mut self) -> Result<(), Status>

Validates the end of a DATA stream, including an empty stream.

Errors

Returns internal for a truncated header or body, or the previous failure.

pub fn reset(&mut self)

Discards buffered input and failure state before decoding a different stream.

Trait Implementations

impl Debug for LengthPrefixedFrame

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for LengthPrefixedFrame

fn default() -> Self

Returns the “default value” for a type.