Struct Reactor 

pub struct Reactor { /* private fields */ }

Thread-owned reactor that wraps the platform-specific backend.

Stored in a RefCell inside the thread-local so that mutable access can be checked at runtime (panics on re-entrant borrow, which must not happen in correct code).

Implementations

impl Reactor

pub fn new() -> Result<Self>

Create a new Reactor, opening the underlying OS polling resource.

pub fn register( &self, source: RawSource, token: usize, interest: Interest, ) -> Result<()>

Register a raw source. Delegates to the platform backend.

pub fn reregister( &self, source: RawSource, token: usize, interest: Interest, ) -> Result<()>

Re-register (update interest) a raw source.

pub fn deregister(&self, source: RawSource) -> Result<()>

Deregister a raw source and remove its wakers from the registry.

pub fn poll( &mut self, events: &mut Events, timeout_ms: Option<u64>, ) -> Result<usize>

Poll for ready events and wake registered task wakers.

Fills events from the platform backend, then fires any wakers whose tokens appear in the event list. Returns the number of events collected.