Struct wisp_mux::ServerMux

pub struct ServerMux { /* 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 ServerMux

pub fn new<R, W: WebSocketWrite>( 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)>

Wait for a stream to be created.

pub async fn close(&self)

Close all streams.

Also terminates the multiplexor future. Waiting for a new stream will never succeed after this function is called.