Struct Reactor 

pub struct Reactor { /* private fields */ }

Polling reactor.

Uses epoll or kqueue, depending on the platform.

Implementations

impl Reactor

pub fn new() -> Result<Reactor, Error>

pub fn with_capacity(io_queue_capacity: u32) -> Result<Reactor, Error>

pub const fn tp(&self) -> DriverType

Reactor type

pub fn register<F>(&self, f: F)

where F: FnOnce(ReactorApi) -> Box<dyn Handler>,

Register updates handler

Trait Implementations

impl AsRawFd for Reactor

fn as_raw_fd(&self) -> i32

Extracts the raw file descriptor.

impl Debug for Reactor

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Driver for Reactor

fn run(&self, rt: &Runtime) -> Result<(), Error>

Poll the driver and handle completed entries.

fn handle(&self) -> Box<dyn Notify>

Get notification handle

fn clear(&self)

Clear handlers

impl Reactor for Reactor

fn tcp_connect(&self, addr: SocketAddr, cfg: SharedCfg) -> Receiver<Io>

Starts an asynchronous TCP connection.

fn unix_connect(&self, addr: PathBuf, cfg: SharedCfg) -> Receiver<Io>

Starts an asynchronous Unix domain socket connection.

fn from_tcp_stream( &self, stream: TcpStream, cfg: SharedCfg, ) -> Result<Io, Error>

Converts a standard-library TCP stream into an Io value.

fn from_unix_stream( &self, stream: UnixStream, cfg: SharedCfg, ) -> Result<Io, Error>

Converts a standard-library Unix stream into an Io value.