Enum virtual_net::rx_tx::RemoteTx

pub(crate) enum RemoteTx<T>
where
    T: Serialize,
{
    Mpsc {
        tx: Sender<T>,
        work: UnboundedSender<BoxFuture<'static, ()>>,
        wakers: RemoteTxWakers,
    },
    Stream {
        tx: Arc<Mutex<Pin<Box<dyn Sink<T, Error = Error> + Send + 'static>>>>,
        work: UnboundedSender<BoxFuture<'static, ()>>,
        wakers: RemoteTxWakers,
    },
    HyperWebSocket {
        tx: Arc<Mutex<SplitSink<WebSocketStream<TokioIo<Upgraded>>, Message>>>,
        work: UnboundedSender<BoxFuture<'static, ()>>,
        wakers: RemoteTxWakers,
        format: FrameSerializationFormat,
    },
    TokioWebSocket {
        tx: Arc<Mutex<SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>>>,
        work: UnboundedSender<BoxFuture<'static, ()>>,
        wakers: RemoteTxWakers,
        format: FrameSerializationFormat,
    },
}

Variants

Mpsc

Fields

tx: Sender<T>

work: UnboundedSender<BoxFuture<'static, ()>>

wakers: RemoteTxWakers

Stream

Fields

tx: Arc<Mutex<Pin<Box<dyn Sink<T, Error = Error> + Send + 'static>>>>

work: UnboundedSender<BoxFuture<'static, ()>>

wakers: RemoteTxWakers

HyperWebSocket

Fields

tx: Arc<Mutex<SplitSink<WebSocketStream<TokioIo<Upgraded>>, Message>>>

work: UnboundedSender<BoxFuture<'static, ()>>

wakers: RemoteTxWakers

format: FrameSerializationFormat

TokioWebSocket

Fields

tx: Arc<Mutex<SplitSink<WebSocketStream<MaybeTlsStream<TcpStream>>, Message>>>

work: UnboundedSender<BoxFuture<'static, ()>>

wakers: RemoteTxWakers

format: FrameSerializationFormat

Implementations

impl<T> RemoteTx<T>

where T: Serialize + Send + Sync + 'static,

pub(crate) async fn send(&self, req: T) -> Result<()>

pub(crate) fn poll_send(&self, cx: &mut Context<'_>, req: T) -> Poll<Result<()>>

pub(crate) fn send_with_driver(&self, req: T) -> Result<()>

Trait Implementations

impl<T> Debug for RemoteTx<T>

where T: Serialize, Sender<T>: Debug,

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

Formats the value using the given formatter.