Struct SchedulerMultiStream 

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

Represents a multi-stream scheduler that manages task execution across multiple streams.

Fields

logger: Arc<ServerLogger>

Server logger.

Implementations

impl<B: SchedulerStreamBackend> SchedulerMultiStream<B>

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

Creates a new SchedulerMultiStream with the given backend and options.

pub fn stream(&mut self, stream_id: &StreamId) -> &mut B::Stream

Returns a mutable reference to the backend stream for a given stream ID.

pub fn register<'a>( &mut self, stream_id: StreamId, task: B::Task, bindings: impl Iterator<Item = &'a Binding>, )

Registers a task for execution on a specific stream, ensuring stream alignment.

pub fn execute_streams(&mut self, stream_ids: Vec<StreamId>)

Executes tasks from the specified streams based on the scheduling strategy.

Trait Implementations

impl<B: Debug + SchedulerStreamBackend> Debug for SchedulerMultiStream<B>

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

Formats the value using the given formatter.