Struct wisp_mux::ServerMux

pub struct ServerMux<W>
where
    W: WebSocketWrite + Send + 'static,
{ /* private fields */ }

Server-side multiplexor.

Example

use wisp_mux::ServerMux;

let (mux, fut) = ServerMux::new(rx, tx, 128);
tokio::spawn(async move {
    if let Err(e) = fut.await {
        println!("error in multiplexor: {:?}", e);
    }
});
while let Some((packet, stream)) = mux.server_new_stream().await {
    tokio::spawn(async move {
        let url = format!("{}:{}", packet.destination_hostname, packet.destination_port);
        // do something with `url` and `packet.stream_type`
    });
}

Implementations

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

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

where R: WebSocketRead,

Create a new server-side multiplexor.

pub async fn server_new_stream( &mut self ) -> Option<(ConnectPacket, MuxStream<W>)>

Wait for a stream to be created.