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 async fn send_to(&self, buf: BytesMut, route_key: &RouteKey) -> Result<()>

Send ‘buf’ to ‘route_key’ using the current ‘line’. If ‘route_key’ does not belong to the current ‘line’, an Err will be returned.

impl PipeLine

pub fn protocol(&self) -> ConnectProtocol

The protocol this pipeline is using