Enum RemoteRx

pub(crate) enum RemoteRx<T>
where
    T: DeserializeOwned,
{
    Mpsc {
        rx: Receiver<T>,
        wakers: RemoteTxWakers,
    },
    Stream {
        rx: Pin<Box<dyn Stream<Item = Result<T>> + Send + 'static>>,
    },
    HyperWebSocket {
        rx: SplitStream<WebSocketStream<TokioIo<Upgraded>>>,
        format: FrameSerializationFormat,
    },
    TokioWebSocket {
        rx: SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>,
        format: FrameSerializationFormat,
    },
}

Variants

Mpsc

Fields

rx: Receiver<T>

wakers: RemoteTxWakers

Stream

Fields

rx: Pin<Box<dyn Stream<Item = Result<T>> + Send + 'static>>

HyperWebSocket

Fields

rx: SplitStream<WebSocketStream<TokioIo<Upgraded>>>

format: FrameSerializationFormat

TokioWebSocket

Fields

rx: SplitStream<WebSocketStream<MaybeTlsStream<TcpStream>>>

format: FrameSerializationFormat

Implementations

impl<T> RemoteRx<T>

where T: DeserializeOwned,

pub(crate) fn poll(&mut self, cx: &mut Context<'_>) -> Poll<Option<T>>

Trait Implementations

impl<T> Debug for RemoteRx<T>

where T: DeserializeOwned, Receiver<T>: Debug,

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

Formats the value using the given formatter.