Struct StreamRegistry 

pub struct StreamRegistry { /* private fields */ }

Per-connection registry of in-flight output streams. Keyed by stream_id — the wire-spec multiplex tag — so a StreamCancel can target one stream without disturbing the rest of the connection (AC #3).

Implementations

impl StreamRegistry

pub fn new() -> StreamRegistry

pub async fn register( &self, stream_id: u16, ) -> Result<Receiver<()>, RegisterError>

Register a new stream. Returns the receiver half the worker task selects on for cancellation, or Err(InUse) if the stream_id is already active on this connection.

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

Signal the named stream to cancel. Returns false if the stream_id is unknown — caller should emit StreamError with unknown_stream.

pub async fn unregister(&self, stream_id: u16)

Remove the stream from the registry once the worker task has finished (normally or via cancel). Idempotent.

pub async fn active_count(&self) -> usize

Trait Implementations

impl Default for StreamRegistry

fn default() -> StreamRegistry

Returns the “default value” for a type.