Struct StreamSlotMap 

pub struct StreamSlotMap { /* private fields */ }

A synchronous stream demultiplexer with explicit ownership transfer on reads.

Implementations

impl StreamSlotMap

pub const fn new(limits: StreamLimits) -> Self

Creates a client map. Zero limits intentionally disable buffering.

pub const fn with_role(limits: StreamLimits, role: EndpointRole) -> Self

Creates an empty map for the specified local HTTP/2 endpoint role.

pub fn open_stream(&mut self, stream_id: i32) -> SlotResult<()>

Opens a stream without allocating receive buffers.

Errors

Rejects invalid/existing identifiers and new local streams after GOAWAY.

pub fn get(&self, stream_id: i32) -> Option<&StreamSlot>

Looks up a stream without consuming events.

pub fn active_stream_count(&self) -> usize

Number of retained stream slots, including closed slots awaiting removal.

pub const fn goaway(&self) -> Option<(i32, u32)>

Most restrictive GOAWAY boundary and its associated HTTP/2 error code.

pub fn push_initial_metadata( &mut self, stream_id: i32, headers: Headers, ) -> SlotResult<()>

Stores the initial header block exactly once, even after it is consumed.

Errors

Rejects unknown/reset streams, duplicate or late headers, and budget excess.

pub fn append_recv_bytes( &mut self, stream_id: i32, bytes: &[u8], ) -> SlotResult<()>

Accepts arbitrary DATA fragmentation and queues complete gRPC envelopes.

Errors

Rejects missing headers, ended/reset streams, malformed flags or excess resources. Rejections preserve accepted frames and partial bytes.

pub fn push_message( &mut self, stream_id: i32, message: StreamMessage, ) -> SlotResult<()>

Queues a complete envelope supplied by an upstream frame decoder.

Errors

Rejects missing headers, ended/reset streams, partial frames or excess resources.

pub fn push_trailing_metadata( &mut self, stream_id: i32, headers: Headers, ) -> SlotResult<()>

Stores trailers or a Trailers-Only response; mark END_STREAM separately.

Errors

Rejects ended/reset streams, duplicate trailers, partial frames or excess resources.

pub fn mark_remote_end_stream(&mut self, stream_id: i32) -> SlotResult<()>

Closes the peer’s sending half; request streams need not carry trailers.

Errors

Rejects unknown/reset streams, duplicate END_STREAM and truncated envelopes.

pub fn mark_local_end_stream(&mut self, stream_id: i32) -> SlotResult<()>

Closes the local sending half independently of the receive queues.

Errors

Rejects unknown/reset streams or duplicate local END_STREAM.

pub fn record_rst_stream( &mut self, stream_id: i32, error_code: u32, ) -> SlotResult<()>

Closes both halves, preserving completed responses for NO_ERROR resets.

Errors

Rejects unknown streams and repeated resets, preserving the first code.

pub fn apply_goaway( &mut self, last_stream_id: i32, error_code: u32, ) -> SlotResult<Vec<i32>>

Prunes excluded local streams; peer-initiated streams remain unaffected. Repeated GOAWAY frames can only reduce the accepted stream boundary.

Errors

Rejects negative boundaries and increases to an established boundary.

pub fn pop_initial_metadata( &mut self, stream_id: i32, ) -> SlotResult<Option<Headers>>

Transfers initial metadata ownership, leaving lifecycle history intact.

Errors

Rejects unknown streams or resets other than completed-response NO_ERROR.

pub fn pop_message( &mut self, stream_id: i32, ) -> SlotResult<Option<StreamMessage>>

Transfers the next message in stream order and releases its byte charge.

Errors

Rejects unknown streams or resets other than completed-response NO_ERROR.

pub fn take_trailers(&mut self, stream_id: i32) -> SlotResult<Option<Headers>>

Transfers trailers exactly once without changing the remote half state.

Errors

Rejects unknown streams or resets other than completed-response NO_ERROR.

pub fn remove_closed_stream(&mut self, stream_id: i32) -> SlotResult<StreamSlot>

Removes a reset or fully closed stream, including any unread events.

Errors

Rejects unknown streams and streams with an open sending half.

Trait Implementations

impl Debug for StreamSlotMap

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

Formats the value using the given formatter.

impl Default for StreamSlotMap

fn default() -> Self

Returns the “default value” for a type.