Struct TokioExecutor 

pub struct TokioExecutor { /* private fields */ }

Implementations

impl TokioExecutor

pub fn new(rt: Handle) -> TokioExecutor

pub fn get_ref(&self) -> &Handle

Returns a reference to the tokio runtime handle.

pub fn block_on_any<F: Future>(&self, future: F) -> F::Output

Block on the current task safely. Usually regular tokio block_on panics if it is already on the tokio task. This allows block on tokio task, using spawn_blocking. Note: This only works on multi-threaded runtime.

pub fn block_until_ctrlc(&self)

Block the current thread until Ctrl+C is received. This is typically used in SF app main function.

Trait Implementations

impl Clone for TokioExecutor

fn clone(&self) -> TokioExecutor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Executor for TokioExecutor

fn spawn<F>(&self, future: F)

where F: Future + Send + 'static, F::Output: Send,

spawns the task to run in background, and returns a join handle where the future’s result can be awaited. If the future panics, the join handle should return an error code. This is primarily used by mssf Bridge to execute user app async callbacks/notifications. User app impl future may panic, and mssf propagates panic as an error in JoinHandle to SF.