[−][src]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 |