Struct single_executor::SleepFutureRunner

pub struct SleepFutureRunner<Q, CS> where
    CS: TryThreadSpawner<()>,  { /* fields omitted */ }

Runs asynchronous sleep functions by launching a separate handler thread. Each new instance of this spawns a thread.

Implementations

impl<'a, Q, CS> SleepFutureRunner<Q, CS> where
    Q: 'static + TimeoutQueue<Item = SleepMessage<CS>> + Send + Sync,
    CS: TryThreadSpawner<()> + TimeFunctions, 

pub fn try_new(queue: Q) -> Result<Self, CS::SpawnError>

Tries to create a new SleepFutureRunner by launching a thread.

pub fn new(queue: Q) -> Self where
    CS: ThreadSpawner<()>, 

Create a new SleepFutureRunner by launching a thread. Requires thread spawning to be infallible.

pub fn sleep_for(&self, time: Duration) -> SleepFuture

Creates a future that sleeps for a given duration from this call.

pub fn sleep_until(&self, instant: CS::InstantType) -> SleepFuture

Creates a future that sleeps until a given CS::InstantType.

pub fn thread_handle(&self) -> &CS::ThreadHandle

Gets a shared reference to the CS::ThreadHandle that is running the sleep operations.

pub fn into_thread_handle(self) -> CS::ThreadHandle

Converts this runner into a . If this is the last runner for this thread then the thread will stop soon.

Trait Implementations

impl<Q: Debug, CS: Debug> Debug for SleepFutureRunner<Q, CS> where
    CS: TryThreadSpawner<()>,
    CS::ThreadHandle: Debug, 

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

Formats the value using the given formatter.