Struct wisp_mux::ClientMux

pub struct ClientMux<W>
where
    W: WebSocketWrite,
{ /* private fields */ }

Client side multiplexor.

Example

use wisp_mux::{ClientMux, StreamType};

let (mux, fut) = ClientMux::new(rx, tx).await?;
tokio::spawn(async move {
    if let Err(e) = fut.await {
        println!("error in multiplexor: {:?}", e);
    }
});
let stream = mux.client_new_stream(StreamType::Tcp, "google.com", 80);

Implementations

impl<W: WebSocketWrite + Send + 'static> ClientMux<W>

pub async fn new<R>( read: R, write: W ) -> Result<(Self, impl Future<Output = Result<(), WispError>>), WispError>

where R: WebSocketRead,

Create a new client side multiplexor.

pub async fn client_new_stream( &self, stream_type: StreamType, host: String, port: u16 ) -> Result<MuxStream<W>, WispError>

Create a new stream, multiplexed through Wisp.