Struct Reactor 

pub struct Reactor { /* private fields */ }

A reactor pattern implementation based on mio::Poll.

Note: This type implement with lockfree structures, so it is only available on platforms that support atomic operations.

Implementations

impl Reactor

pub fn register<S>( &self, source: &mut S, token: Token, interests: Interest, ) -> Result<()>

where S: Source + ?Sized,

Register an event::Source with the underlying mio::Poll instance.

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

where S: Source + ?Sized,

Deregister an event::Source from the underlying mio::Poll instance.

pub fn deadline( &self, token: Token, waker: Waker, deadline: Instant, ) -> Option<u64>

Create new deadline timer, returns None if the deadline instant is reached.

pub fn once(&self, token: Token, interests: Interest, waker: Waker)

Add a interests listener to this reactor.

pub fn notify(&self, token: Token, interests: Interest)

notify listener by Token and interests

pub fn remove_listeners(&self, token: Token, interests: Interest)

remove listener from this reactor by Token and interests