Struct StreamTable 

pub struct StreamTable { /* private fields */ }

Tracks active streams and their current state for a single connection.

Implementations

impl StreamTable

pub fn new() -> Self

Create an empty stream table.

pub fn insert( &mut self, stream_id: StreamId, state: StreamState, ) -> Result<(), ProtocolError>

Insert a new active stream in the requested state.

Errors

Returns ProtocolError::CodecError when the stream already exists in the table.

pub fn transition( &mut self, stream_id: StreamId, new_state: StreamState, ) -> Result<(), ProtocolError>

Transition an existing stream to a new state.

Errors

Returns ProtocolError::CodecError when the stream is not present in the table.

pub fn remove(&mut self, stream_id: StreamId) -> Option<StreamState>

Remove a stream from the table and return its previous state.

pub fn get(&self, stream_id: StreamId) -> Option<StreamState>

Return the tracked state for a stream.

pub fn active_count(&self) -> usize

Return the number of streams currently tracked in the table.

Trait Implementations

impl Debug for StreamTable

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

Formats the value using the given formatter.

impl Default for StreamTable

fn default() -> StreamTable

Returns the “default value” for a type.