Struct threader::reactor::Reactor

pub struct Reactor { /* fields omitted */ }

The reactor. This is the part of the thread pool that drives IO resources using the system selector.

Methods

impl Reactor

pub fn new() -> Self

Creates a new Reactor with the default event capacity.

pub fn with_capacity(capacity: usize) -> Self

Creates a new Reactor with the given event capacity.

pub fn register<E: Evented>(
    &self,
    resource: &E,
    interest: Ready,
    opts: PollOpt
) -> Result<Arc<IoWaker>>

Registers a new IO resource with this reactor.

pub fn reregister<E: Evented>(
    &self,
    resource: &E,
    io_waker: &IoWaker,
    interest: Ready,
    opts: PollOpt
) -> Result<()>

pub fn deregister<E: Evented>(
    &self,
    resource: &E,
    io_waker: &IoWaker
) -> Result<()>

Deregisters an IO resource with this reactor.

pub fn handle(&self) -> Handle

Creates a new handle to this reactor.

pub fn poll(&mut self, timeout: Option<Duration>) -> Result<usize>

Polls the reactor once, notifying IO resources if any events were detected. This is usually done in a loop, and will most likely not return an error unless there was an error with the system selector.

Trait Implementations

impl Debug for Reactor

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

Formats the value using the given formatter.