Struct MultiStream 

pub struct MultiStream<B: EventStreamBackend> {
    pub logger: Arc<ServerLogger>,
    /* private fields */
}

Manages multiple streams with synchronization logic based on shared bindings.

This struct handles the creation and alignment of streams to ensure proper synchronization when bindings (e.g., buffers) are shared across different streams.

Fields

logger: Arc<ServerLogger>

The logger used by the server.

Implementations

impl<B: EventStreamBackend> MultiStream<B>

pub fn new(logger: Arc<ServerLogger>, backend: B, max_streams: u8) -> Self

Creates an empty multi-stream.

pub fn gc(&mut self, gc: GcTask<B>)

Enqueue a task to be cleaned.

pub fn resolve<'a>( &mut self, stream_id: StreamId, bindings: impl Iterator<Item = &'a Binding>, ) -> ResolvedStreams<'_, B>

Resolves and returns a mutable reference to the stream for the given ID, performing any necessary alignment based on the provided bindings.

This method ensures that the stream is synchronized with any shared bindings from other streams before returning the stream reference.

Trait Implementations

impl<B: Debug + EventStreamBackend> Debug for MultiStream<B>

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

Formats the value using the given formatter.