Reactor

Trait Reactor 

Source
pub trait Reactor: Driver {
    // Required methods
    fn tcp_connect(&self, addr: SocketAddr, cfg: SharedCfg) -> Receiver<Io> ;
    fn unix_connect(&self, addr: PathBuf, cfg: SharedCfg) -> Receiver<Io> ;
    fn from_tcp_stream(&self, stream: TcpStream, cfg: SharedCfg) -> Result<Io>;
    fn from_unix_stream(&self, _: UnixStream, _: SharedCfg) -> Result<Io>;
}

Required Methods§

Source

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

Source

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

Source

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

Convert std TcpStream to Io

Source

fn from_unix_stream(&self, _: UnixStream, _: SharedCfg) -> Result<Io>

Convert std UnixStream to Io

Implementors§

Source§

impl Reactor for ntex_net::polling::Driver

Source§

impl Reactor for ntex_net::uring::Driver