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 backend_mut(&mut self) -> &mut B

Mutable access to the scheduling backend, e.g. to change the configuration new streams are created with. Already-created streams are unaffected.

pub fn streams(&self) -> impl Iterator<Item = &B::Stream>

Read-only iterator over initialized backend streams.

pub fn stream_ids(&self) -> impl Iterator<Item = StreamId> + '_

Synthetic StreamIds, one per initialized stream (see StreamPool::stream_ids).

pub fn register( &mut self, stream_id: StreamId, task: B::Task, args_streams: &[StreamId], )

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.