Struct InputStreamRegistry 

pub struct InputStreamRegistry { /* private fields */ }

Per-connection registry of in-flight input streams. Keyed by stream_id, separate from the output-stream worker registry so an input and an output stream may share one connection without colliding (AC #2).

Implementations

impl InputStreamRegistry

pub fn new() -> InputStreamRegistry

pub fn register( &mut self, stream_id: u16, state: InputStreamState, ) -> Result<(), RegisterError>

Register a freshly-opened input stream. Mirrors the output registry’s reserved-id / duplicate guards and reuses its RegisterError codes so clients see one taxonomy.

pub fn get_mut(&mut self, stream_id: u16) -> Option<&mut InputStreamState>

pub fn contains(&self, stream_id: u16) -> bool

pub fn remove(&mut self, stream_id: u16) -> Option<InputStreamState>

Drop the stream from the registry, returning its state so the caller can read final stats for a terminal frame. Idempotent — a second remove returns None.

pub fn active_count(&self) -> usize

Trait Implementations

impl Default for InputStreamRegistry

fn default() -> InputStreamRegistry

Returns the “default value” for a type.