Struct actix_ws::Session

pub struct Session { /* fields omitted */ }

A handle into the websocket session.

This type can be used to send messages into the websocket.

Implementations

impl Session

pub async fn text<'_, T>(&'_ mut self, msg: T) -> Result<(), Closed> where
    T: Into<String>, 

Send text into the websocket

if session.text("Some text").await.is_err() {
    // session closed
}

pub async fn binary<'_, T>(&'_ mut self, msg: T) -> Result<(), Closed> where
    T: Into<Bytes>, 

Send raw bytes into the websocket

if session.binary(b"some bytes").await.is_err() {
    // session closed
}

pub async fn ping<'_, '_>(&'_ mut self, msg: &'_ [u8]) -> Result<(), Closed>

Ping the client

For many applications, it will be important to send regular pings to keep track of if the client has disconnected

if session.ping(b"").await.is_err() {
    // session is closed
}

pub async fn pong<'_, '_>(&'_ mut self, msg: &'_ [u8]) -> Result<(), Closed>

Pong the client

match msg {
    Message::Ping(bytes) => {
        let _ = session.pong(&bytes).await;
    }
    _ => (),
}

pub async fn close(
    __arg0: Self,
    reason: Option<CloseReason>
) -> Result<(), Closed>

Send a close message, and consume the session

All clones will return Err(Closed) if used after this call

session.close(None).await

Trait Implementations

impl Clone for Session

fn clone(&self) -> Session

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.