Struct SchedulerForegroundExecutor 

pub struct SchedulerForegroundExecutor { /* private fields */ }

Implementations

impl ForegroundExecutor

pub fn new( session_id: SessionId, scheduler: Arc<dyn Scheduler>, ) -> ForegroundExecutor

pub fn session_id(&self) -> SessionId

pub fn scheduler(&self) -> &Arc<dyn Scheduler>

pub fn spawn<F>(&self, future: F) -> Task<<F as Future>::Output>

where F: Future + 'static, <F as Future>::Output: 'static,

pub fn block_on<Fut>(&self, future: Fut) -> <Fut as Future>::Output

where Fut: Future,

pub fn block_with_timeout<Fut>( &self, timeout: Duration, future: Fut, ) -> Result<<Fut as Future>::Output, impl Future<Output = <Fut as Future>::Output> + use<Fut>>

where Fut: Future,

Block until the future completes or timeout occurs. Returns Ok(output) if completed, Err(future) if timed out.

pub fn timer(&self, duration: Duration) -> Timer

pub fn now(&self) -> Instant

Trait Implementations

impl Clone for ForegroundExecutor

fn clone(&self) -> ForegroundExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.