Module poem::web::websocket

This is supported on crate feature websocket only.

Websocket extractor and response.

Example

use futures_util::{SinkExt, StreamExt};
use poem::{
    handler, route,
    web::websocket::{Message, WebSocket},
    IntoResponse,
};

#[handler(method = "get")]
async fn index(ws: WebSocket) -> impl IntoResponse {
    ws.on_upgrade(|mut socket| async move {
        if let Some(Ok(Message::Text(text))) = socket.next().await {
            let _ = socket.send(Message::Text(text)).await;
        }
    })
}

let app = route().at("/", index);

Structs

WebSocket

An extractor that can accept websocket connections.

WebSocketStream

A WebSocket stream, which implements [Stream<Message>] and [Sink<Message>].

Enums

CloseCode

Status code used to indicate why an endpoint is closing the WebSocket connection.

Message

An enum representing the various forms of a WebSocket message.