Trait Scheduler 

pub trait Scheduler:
    WithWorkInputOutput
    + WithWorkContextProvider
    + Send
    + Sync {
    type DelayedWorkFactory: DelayedWorkFactory<Self::Tick, Self::WorkContextProvider>;
    type RepeatedWorkFactory: RepeatedTaskFactory<Self::Tick, Self::WorkContextProvider>;
    type ContinuousWorkFactory: ContinuousTaskFactory<Self::Tick, Self::WorkContextProvider>;
    type ImmediateWorkFactory: ImmediateTaskFactory<Self::Tick, Self::WorkContextProvider>;
    type InvokedWorkFactory: InvokedTaskFactory<Self::Tick, Self::WorkContextProvider>;

    // Required methods
    fn schedule_work<W>(&mut self, work: W, cancellation_id: WorkCancellationId)
       where W: 'static + ScheduledWork<Tick = Self::Tick, WorkContextProvider = Self::WorkContextProvider> + Send + Sync;
    fn schedule_invoked_work<W>(&mut self, work: W, invoke_id: WorkInvokeId)
       where W: 'static + ScheduledWork<Tick = Self::Tick, WorkContextProvider = Self::WorkContextProvider> + Send + Sync;
    fn cancel(&mut self, cancellation_id: WorkCancellationId);
    fn invoke(&mut self, invoke_id: WorkInvokeId);
    fn cancel_invoked(&mut self, invoke_id: WorkInvokeId);
    fn generate_cancellation_id(&mut self) -> WorkCancellationId;
    fn generate_invoke_id(&mut self) -> WorkInvokeId;
}

Schedulers define a set of work that can be sent to the scheduler to then be executed by its executor, and cancelled when no longer needed.

Required Associated Types

type DelayedWorkFactory: DelayedWorkFactory<Self::Tick, Self::WorkContextProvider>

type RepeatedWorkFactory: RepeatedTaskFactory<Self::Tick, Self::WorkContextProvider>

type ContinuousWorkFactory: ContinuousTaskFactory<Self::Tick, Self::WorkContextProvider>

type ImmediateWorkFactory: ImmediateTaskFactory<Self::Tick, Self::WorkContextProvider>

type InvokedWorkFactory: InvokedTaskFactory<Self::Tick, Self::WorkContextProvider>

Required Methods

fn schedule_work<W>(&mut self, work: W, cancellation_id: WorkCancellationId)

where W: 'static + ScheduledWork<Tick = Self::Tick, WorkContextProvider = Self::WorkContextProvider> + Send + Sync,

fn schedule_invoked_work<W>(&mut self, work: W, invoke_id: WorkInvokeId)

where W: 'static + ScheduledWork<Tick = Self::Tick, WorkContextProvider = Self::WorkContextProvider> + Send + Sync,

fn cancel(&mut self, cancellation_id: WorkCancellationId)

fn invoke(&mut self, invoke_id: WorkInvokeId)

fn cancel_invoked(&mut self, invoke_id: WorkInvokeId)

fn generate_cancellation_id(&mut self) -> WorkCancellationId

fn generate_invoke_id(&mut self) -> WorkInvokeId

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<C> Scheduler for TickingScheduler<C>

where C: 'static + WorkContextProvider + Send + Sync,

type DelayedWorkFactory = TickedDelayedOnceWorkFactory<C>

type ImmediateWorkFactory = TickedImmediateOnceWorkFactory<C>

type RepeatedWorkFactory = TickedRepeatingWorkFactory<C>

type InvokedWorkFactory = TickedInvokedWorkFactory<C>

type ContinuousWorkFactory = TickedContinuousWorkFactory<C>