Struct Reactor 

pub struct Reactor<'l, C: Clock> { /* private fields */ }

The reactor of one executor: registrations made by the futures it hands out.

Implementations

impl<'l, C: Clock> Reactor<'l, C>

pub fn new(clock: C) -> Self

An empty reactor reading clock.

pub fn clock(&self) -> &C

The clock the reactor reads.

pub fn ready( &self, desc: MemoryDescriptor<'l>, until: Option<MonoNs>, ) -> Ready<'_, 'l, C>

A future that resolves true once desc completes, or false once the clock reads until first (no bound with None).

pub fn pending(&self) -> (usize, usize)

Registered descriptors and timers (for a host’s counters and tests).

pub fn turn<I: Idle>( &self, idle: &mut I, park_bound: DurNs, tasks_left: usize, ) -> Result<Turn>

The executor’s step when no task is ready (module docs).

Errors

Stalled when nothing is registered: no store and no timer can ever wake the executor.

pub fn fire(&self) -> bool

Wake every task whose descriptor completed or whose deadline passed, without idling; true if any was woken. The executor calls this between task polls, so a completion becomes ready work as soon as it lands, not only when the thread runs out of work.

impl<'l, C: Clock> Reactor<'l, C>

pub fn alarm(&self, at: MonoNs) -> Alarmed<'_, 'l, C>

A future that resolves once the clock reads at; the executor sleeps to the earliest one.

Trait Implementations

impl<C: Clock> Clock for Reactor<'_, C>

fn monotonic_ns(&self) -> MonoNs

Monotonic nanoseconds from the host’s origin.

impl<C: Clock> Timer for Reactor<'_, C>

async fn sleep_until(&self, at: MonoNs)

Resolves once the host clock reads at or later.