Struct StreamMultiplexer 

pub struct StreamMultiplexer { /* private fields */ }

Stream multiplexer for managing multiple logical streams

Implementations

impl StreamMultiplexer

pub fn new() -> Self

Create a new stream multiplexer

pub fn with_config(config: FlowControlConfig) -> Self

Create a new stream multiplexer with custom flow control config

pub async fn create_stream( &self, request_id: Option<Uuid>, ) -> Result<StreamHandle, ProtocolError>

Create a new stream

pub async fn route_frame(&self, frame: Frame) -> Result<(), ProtocolError>

Route an incoming frame to the appropriate stream

pub async fn close_stream(&self, stream_id: u32) -> Result<(), ProtocolError>

Close a stream

pub async fn stream_count(&self) -> usize

Get the number of active streams

pub async fn stream_state(&self, stream_id: u32) -> Option<StreamState>

Get stream state

pub async fn process_frames(&self) -> Result<(), ProtocolError>

Process incoming frames (should be called in a loop)

pub fn send_frame(&self, frame: Frame) -> Result<(), ProtocolError>

Send a frame through the multiplexer

pub async fn can_send_data( &self, stream_id: u32, size: u32, ) -> Result<bool, ProtocolError>

Check if a stream can send data of the given size

pub async fn update_window( &self, stream_id: u32, delta: u32, ) -> Result<(), ProtocolError>

Update flow control window for a stream

pub async fn process_received_data( &self, stream_id: u32, size: u32, ) -> Result<(), ProtocolError>

Process received data and update flow control

pub async fn ack_processed_data( &self, stream_id: u32, size: u32, ) -> Result<(), ProtocolError>

Acknowledge processed data and return credits

Trait Implementations

impl Clone for StreamMultiplexer

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for StreamMultiplexer

fn default() -> Self

Returns the “default value” for a type.