Struct H2StreamReassembler 

pub struct H2StreamReassembler { /* private fields */ }

Per-stream HEADERS+CONTINUATION accumulator (Phase 3g.1).

One instance per h2 connection, fed every HEADERS / CONTINUATION frame the proxy parses. Returns the completed (stream-id, block) pair when END_HEADERS is observed; otherwise tracks the pending reassembly internally.

Non-HEADERS / non-CONTINUATION frames pass through with Ok(None). A non-CONTINUATION frame from any stream while a reassembly is open on another stream is rejected as H2ParseError::InterleavedFrame (RFC 7540 §6.10).

Implementations

impl H2StreamReassembler

pub fn new() -> Self

Construct a fresh reassembler with no pending streams.

pub fn ingest( &mut self, frame: &FrameHeader, payload: &[u8], ) -> Result<Option<(u32, Vec<u8>)>, H2ParseError>

Feed a single frame’s (header, payload) pair.

Returns:

• Ok(Some((stream_id, block))) — the frame completed a HEADERS+CONTINUATION block. The block has had padding + priority stripped (frame layer) and is the concatenated header block fragment ready for HpackDecoder::decode_block.
• Ok(None) — the frame either was not HEADERS/CONTINUATION (passed through; pure flow-control or DATA), or was HEADERS without END_HEADERS (more bytes needed), or was a CONTINUATION without END_HEADERS (more bytes needed).
• Err(InterleavedFrame) — RFC 7540 §6.10 violation: a frame appeared between HEADERS and the END_HEADERS-bearing CONTINUATION on the same stream; or a CONTINUATION arrived for a stream that does NOT have an open reassembly.
• Err(ReassemblerOverflow) — one of the defensive bounds tripped; caller RST_STREAMs the offending stream id.

Trait Implementations

impl Default for H2StreamReassembler

fn default() -> Self

Returns the “default value” for a type.