Skip to main content

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, Error>;
    fn from_unix_stream(&self, _: UnixStream, _: SharedCfg) -> Result<Io, Error>;
}

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, Error>

Convert std TcpStream to Io

Source

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

Convert std UnixStream to Io

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§

Source§

impl Reactor for ntex::rt::polling::Driver

Source§

impl Reactor for ntex::rt::uring::Driver