Crate roa_websocket

This crate provides a websocket endpoint.

Example

use futures::StreamExt;
use roa_router::{Router, RouterError};
use roa_websocket::Websocket;
use roa_core::{App, Context};
use roa_core::http::Method;

let router = Router::new().on("/chat", Websocket::new(|_ctx: Context<()>, stream| async move {
    let (write, read) = stream.split();
    // echo
    if let Err(err) = read.forward(write).await {
        println!("forward err: {}", err);
    }
}));
let app = App::new(()).end(router.routes("/")?);
Ok(())

Re-exports

pub use tokio_tungstenite::tungstenite;

Structs

WebSocketConfig	The configuration for WebSocket connection.
Websocket	The Websocket middleware.

Enums

Message

An enum representing the various forms of a WebSocket message.

Type Definitions

SocketStream

An alias for WebSocketStream.