Trait SessionStream

pub(crate) trait SessionStream:
    AsyncRead
    + AsyncWrite
    + Unpin
    + Send
    + Sync
    + Debug {
    // Required methods
    fn set_read_timeout(&mut self, timeout: Option<Duration>);
    fn peer_addr(&self) -> Result<SocketAddr>;
}

Required Methods

fn set_read_timeout(&mut self, timeout: Option<Duration>)

Change the read timeout on the session stream.

fn peer_addr(&self) -> Result<SocketAddr>

Returns the remote address that this stream is connected to.

Trait Implementations

impl SessionStream for Box<dyn SessionStream>

fn set_read_timeout(&mut self, timeout: Option<Duration>)

Change the read timeout on the session stream.

fn peer_addr(&self) -> Result<SocketAddr>

Returns the remote address that this stream is connected to.

Implementations on Foreign Types

impl SessionStream for Box<dyn SessionStream>

fn set_read_timeout(&mut self, timeout: Option<Duration>)

fn peer_addr(&self) -> Result<SocketAddr>

impl SessionStream for Pin<Box<TimeoutStream<TcpStream>>>

fn set_read_timeout(&mut self, timeout: Option<Duration>)

fn peer_addr(&self) -> Result<SocketAddr>

impl<T: SessionStream> SessionStream for BufStream<T>

fn set_read_timeout(&mut self, timeout: Option<Duration>)

fn peer_addr(&self) -> Result<SocketAddr>

impl<T: SessionStream> SessionStream for BufWriter<T>

fn set_read_timeout(&mut self, timeout: Option<Duration>)

fn peer_addr(&self) -> Result<SocketAddr>

impl<T: SessionStream> SessionStream for DeflateStream<T>

fn set_read_timeout(&mut self, timeout: Option<Duration>)

fn peer_addr(&self) -> Result<SocketAddr>

impl<T: SessionStream> SessionStream for ProxyClientStream<T>

fn set_read_timeout(&mut self, timeout: Option<Duration>)

fn peer_addr(&self) -> Result<SocketAddr>

impl<T: SessionStream> SessionStream for Socks5Stream<T>

fn set_read_timeout(&mut self, timeout: Option<Duration>)

fn peer_addr(&self) -> Result<SocketAddr>

impl<T: SessionStream> SessionStream for TlsStream<T>

fn set_read_timeout(&mut self, timeout: Option<Duration>)

fn peer_addr(&self) -> Result<SocketAddr>

impl<T: SessionStream> SessionStream for TlsStream<T>

fn set_read_timeout(&mut self, timeout: Option<Duration>)

fn peer_addr(&self) -> Result<SocketAddr>

Implementors

impl<S: SessionStream> SessionStream for LoggingStream<S>