Struct Scheduler 

pub struct Scheduler { /* private fields */ }

Implementations

impl Scheduler

pub fn new() -> Self

pub fn request_flush(&self) -> FlushDecision

Request a flush attempt.

• flush_waiting is always set on request.
• A flush starts immediately only when no run is in-flight.
• While busy, flush is deferred without blocking new runs.

pub fn finish_flush(&self)

Mark the active flush as completed and release all pending runs.

pub fn snapshot(&self) -> Snapshot

pub async fn submit_run<O, F>( &self, options: RunOptions, op: F, ) -> Result<O, Error>

where O: Send + 'static, F: Future<Output = O> + Send + 'static,

Trait Implementations

impl Clone for Scheduler

fn clone(&self) -> Scheduler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for Scheduler

fn default() -> Scheduler

Returns the “default value” for a type.