Struct StreamPool 

pub struct StreamPool<F: StreamFactory> { /* private fields */ }

Represents a pool of streams, managing a collection of streams created by a factory.

Implementations

impl<F: StreamFactory> StreamPool<F>

pub fn new(backend: F, max_streams: u8, num_special: u8) -> Self

Creates a new stream pool with the given backend factory and capacity constraints.

pub fn get_mut(&mut self, stream_id: &StreamId) -> &mut F::Stream

Retrieves a mutable reference to a stream for a given stream ID.

pub unsafe fn get_mut_index(&mut self, index: usize) -> &mut F::Stream

Retrieves a mutable reference to a stream at the specified index, initializing it if needed.

Safety

• Caller must ensure the index is valid (less than max_streams + num_special).
• Lifetimes still follow the Rust rules.

pub unsafe fn get_special(&mut self, index: u8) -> &mut F::Stream

Retrieves a mutable reference to a special stream at the given index.

Safety

• Caller must ensure the index corresponds to a valid special stream.
• Lifetimes still follow the Rust rules.

pub fn stream_index(&mut self, id: &StreamId) -> usize

Calculates the index for a given stream ID, mapping it to the pool’s capacity.

Trait Implementations

impl<F: Debug + StreamFactory> Debug for StreamPool<F>

where F::Stream: Debug,

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

Formats the value using the given formatter.