Struct Reactor 

pub struct Reactor { /* private fields */ }

The executor that owns the reactor — the capability a reactor-bound task is spawned through.

Hold one and you may spawn a future that opens a tokio::net socket, waits on tokio::time, or installs a signal handler. The counterpart is spawn_background, which needs no capability because the executor it lands on is process-global — and, for the same reason, has no reactor.

Where one comes from

Reactor::current mints one from the runtime entered on the calling thread, and returns None rather than panicking when there is none. Everything else receives one: the IOC and the CA/PVA servers and clients capture it once on their own setup path and hand &Reactor down to the tasks they start. BlockingBridge::reactor is the third source, for a blocking thread the runtime is not entered on.

Implementations

impl Reactor

pub fn current() -> Option<Self>

The runtime entered on this thread, or None when there is none.

Deliberately not a panicking constructor: the ambient spawn this replaces panicked from inside itself, which is exactly the failure the capability exists to move into the type. A caller that genuinely cannot continue without one writes its own expect, which names the reason and can be found by a census.

pub fn spawn<F>(&self, future: F) -> TaskHandle<F::Output>

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

Spawn a reactor-bound future.

Works from any thread, including one the runtime is not entered on — the handle carries the runtime, where tokio::spawn read a thread-local.

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

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

Run a blocking closure on the runtime’s blocking pool.

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.

impl Debug for Reactor

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

Formats the value using the given formatter.