Enum TokioExec 

pub enum TokioExec {
    Runtime(Arc<Runtime>),
    Handle(Handle),
}

The main struct for tokio runtime IO, assign this type to AsyncIO trait when used.

Variants

Runtime(Arc<Runtime>)

Handle(Handle)

Implementations

impl TokioExec

pub fn new_with_runtime(rt: Runtime) -> Self

Capture a runtime

pub fn new_multi_thread(workers: usize) -> Self

pub fn new_current_thread() -> Self

pub fn new_with_handle(handle: Handle) -> Self

Only capture a runtime handle. Should acquire with async { Handle::current() }

Trait Implementations

impl AsyncExec for TokioExec

fn spawn<F, R>(&self, f: F) -> TokioJoinHandle<R>

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

Spawn a task in the background, returning a handle to await its result

fn spawn_detach<F, R>(&self, f: F)

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

Spawn a task and detach it (no handle returned)

fn block_on<F, R>(&self, f: F) -> R

where F: Future<Output = R>, R: 'static,

Run a future to completion on the runtime

type AsyncJoiner<R: Send> = TokioJoinHandle<R>

type ThreadJoiner<R: Send> = TokioThreadHandle<R>

fn spawn_blocking<F, R>(&self, f: F) -> TokioThreadHandle<R>

where F: FnOnce() -> R + Send + 'static, R: Send + 'static,

Run blocking code in a background thread pool, and return an async join handle

impl Clone for TokioExec

fn clone(&self) -> Self

Clone a TokioRT::Handle out of runtime, for spawn

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

Performs copy-assignment from source.

impl Debug for TokioExec

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

Formats the value using the given formatter.