Enum PipeLine

pub enum PipeLine {
    Udp(UdpPipeLine),
    Tcp(TcpPipeLine),
    Extend(ExtensiblePipeLine),
}

Variants

Udp(UdpPipeLine)

Tcp(TcpPipeLine)

Extend(ExtensiblePipeLine)

Implementations

impl PipeLine

pub async fn recv_from( &mut self, buf: &mut [u8], ) -> Option<Result<(usize, RouteKey)>>

Receving buf from the associated PipeLine usize in the Ok branch indicates how many bytes are received RouteKey in the Ok branch denotes the source where these bytes are received from

pub fn done(&mut self)

impl PipeLine

pub fn protocol(&self) -> ConnectProtocol

The protocol this pipeline is using

pub fn remote_addr(&self) -> Option<SocketAddr>