Struct wisp_mux::MuxStreamWrite

pub struct MuxStreamWrite<W>
where
    W: WebSocketWrite,
{
    pub stream_id: u32,
    /* private fields */
}

Write side of a multiplexor stream.

Fields

stream_id: u32

ID of the stream.

Implementations

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

pub async fn write(&self, data: Bytes) -> Result<(), WispError>

Write data to the stream.

pub fn get_close_handle(&self) -> MuxStreamCloser

Get a handle to close the connection.

Useful to close the connection without having access to the stream.

Example

let handle = stream.get_close_handle();
if let Err(error) = handle_stream(stream) {
    handle.close(0x01);
}

pub async fn close(&self, reason: CloseReason) -> Result<(), WispError>

Close the stream. You will no longer be able to write or read after this has been called.

Trait Implementations

impl<W: WebSocketWrite> Drop for MuxStreamWrite<W>

fn drop(&mut self)

Executes the destructor for this type.