Struct Reactor 

pub struct Reactor { /* private fields */ }

Available on Windows only.

A handle for submitting work to a reactor.

Cloneable. The reactor thread implicitly shuts down after all clones are dropped and no work remains.

Implementations

impl Reactor

pub async fn new() -> Result<(Reactor, Control)>

Spawns the reactor thread, returning a cloneable submission handle alongside the unique handle that controls its lifecycle.

pub fn submit<T, F>(&self, f: F) -> Result<Task<T>, Closed>

where T: Send + 'static, F: AsyncFnOnce(&mut Context) -> T + Send + 'static,

Submits f to run on the reactor thread, returning a future for its result.

f receives a Context for cooperative cancellation (Context::cancel_guard) and task self-submission (Context::submit).

Fails with Closed once Control::close has been called.

Trait Implementations

impl Clone for Reactor

fn clone(&self) -> Reactor

Returns a duplicate of the value.

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

Performs copy-assignment from source.