Struct smartpool::timescheduler::TimeScheduler

pub struct TimeScheduler { /* fields omitted */ }

A thread that schedules events to occur in the future.

Methods

impl TimeScheduler

pub fn new() -> Self

pub fn at(&self, moment: SteadyTime) -> FutureMoment

A future that occurs at the given moment.

pub fn after(&self, delay: Duration) -> FutureMoment

A future that occurs after the given delay.

pub fn periodically(
    &self,
    start: SteadyTime,
    period: Duration
) -> PeriodicMoments

A stream that produces values on a set interval.

pub fn run_at(
    &self,
    moment: SteadyTime,
    future: impl Future<Item = (), Error = ()> + Send + 'static,
    exec: impl Exec + Send + 'static
)

Run a future in an executor at a moment in the future.

pub fn run_at_param<P: Send + 'static>(
    &self,
    moment: SteadyTime,
    future: impl Future<Item = (), Error = ()> + Send + 'static,
    exec: impl ExecParam<Param = P> + Send + 'static,
    param: P
)

Run a future in an executor with a parameter at a moment in the future.

pub fn run_after(
    &self,
    delay: Duration,
    future: impl Future<Item = (), Error = ()> + Send + 'static,
    exec: impl Exec + Send + 'static
)

Run a future in an executor after a delay.

pub fn run_after_param<P: Send + 'static>(
    &self,
    delay: Duration,
    future: impl Future<Item = (), Error = ()> + Send + 'static,
    exec: impl ExecParam<Param = P> + Send + 'static,
    param: P
)

Run a future in an executor with a parameter after a delay.

Trait Implementations

impl Clone for TimeScheduler

fn clone(&self) -> TimeScheduler

Returns a copy of the value.

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

Performs copy-assignment from source.