Struct Decoder 

pub struct Decoder { /* private fields */ }

Available on crate features http-backend and http and std only.

A stateful QPACK decoder for one connection.

Implementations

impl Decoder

pub fn new(config: DecoderConfig) -> Decoder

Create a decoder with the given limits.

pub fn insert_count(&self) -> u64

The decoder’s current dynamic-table insert count.

pub fn blocked_stream_count(&self) -> usize

The number of currently blocked streams.

pub fn take_decoder_stream(&mut self) -> Bytes

Take the queued decoder-stream bytes to send to the peer, leaving the queue empty.

pub fn feed_encoder_stream(&mut self, input: &[u8]) -> Result<(), QpackError>

Feed bytes received on the peer’s encoder stream, applying every complete instruction.

Retains a trailing partial instruction for the next call (transactional), and emits Insert Count Increment for entries inserted. Any newly unblocked streams should then be collected with Decoder::resume_blocked. OutputBlocked consumes no input: drain the decoder stream and retry. If the queue is already empty, split the input into smaller batches: reservation bounds the increment by the input byte count. Other errors are fatal connection errors; do not retry them.

pub fn decode_field_section( &mut self, stream_id: u64, encoded: Bytes, ) -> Result<Option<Vec<FieldPair>>, QpackError>

Decode a complete encoded field section received on stream stream_id.

The full section must be buffered by the caller (the frame layer bounds its length first). Returns Ok(Some(fields)) when it decodes immediately, or Ok(None) when it is blocked on the Required Insert Count, in which case it is retained (subject to the blocked budget) and returned later by Decoder::resume_blocked.

Immediately decoded literals share the supplied allocation. Queued sections are compacted to avoid retaining an arbitrarily large backing allocation through a small slice. Retain a cheap Bytes clone until success: OutputBlocked leaves state unchanged, so drain and retry. On FieldSectionLimit, queued sections for this stream are released. The caller must reset the stream and call Decoder::cancel_stream (draining and retrying if necessary) to notify the peer and release its references.

pub fn resume_blocked( &mut self, ) -> Vec<(u64, Result<Vec<FieldPair>, QpackError>)>

Decode and remove blocked sections whose Required Insert Count is now satisfied.

Each stream’s sections are resumed front-first and only while the front is ready, so a stream’s sections are never delivered out of order. A decode failure is reported per stream. OutputBlocked leaves the section queued; drain output before resuming again. A FieldSectionLimit releases all queued sections for that stream; reset it and call Decoder::cancel_stream to release the peer’s references.

pub fn cancel_stream(&mut self, stream_id: u64) -> Result<(), QpackError>

Cancel a stream: drop any blocked sections and emit Stream Cancellation (RFC 9204 §4.4.2). OutputBlocked leaves blocked sections intact; drain output and retry.