Enum veloren_network::channel::RecvProtocols

pub(crate) enum RecvProtocols {
    Tcp(TcpRecvProtocol<TcpSink>),
    Mpsc(MpscRecvProtocol<MpscSink>),
    Quic(QuicRecvProtocol<QuicSink>),
}

Variants

Tcp(TcpRecvProtocol<TcpSink>)

Mpsc(MpscRecvProtocol<MpscSink>)

Quic(QuicRecvProtocol<QuicSink>)

Trait Implementations

impl Debug for RecvProtocols

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RecvProtocol for RecvProtocols

type CustomErr = ProtocolsError

fn recv<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<ProtocolEvent, ProtocolError<Self::CustomErr>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Either recv an event or fail the Protocol, once the Recv side is closed it cannot recover from the error.