Struct ReactorSystem 

pub struct ReactorSystem { /* private fields */ }

Lightweight dispatch handle for the reactor system.

Sits at the driver level (same as mio Poll or timer poller). Reads ReactorNotify via pre-resolved ResourceId during dispatch. All reactor storage and registration lives in ReactorNotify (World resource).

Implementations

impl ReactorSystem

pub fn new(world: &World) -> Self

Create a dispatch handle from a built World.

The World must contain ReactorNotify and DeferredRemovals.

pub fn dispatch(&mut self, world: &mut World) -> bool

Dispatch all woken reactors and process deferred removals.

1. Polls ReactorNotify for woken reactor tokens (deduped)
2. Runs each reactor’s step function with pre-resolved Params
3. Drains DeferredRemovals and removes reactors

Returns true if any reactor ran (for scheduler propagation).

pub fn reactor_count(&self, world: &World) -> usize

Number of live reactors.