Roa-websocket

This crate provides a websocket endpoint.

Example

```rust use futures::StreamExt; use roarouter::{Router, RouterError}; use roawebsocket::Websocket; use roacore::{App, SyncContext}; use roacore::http::Method;

fn main() -> Result<(), RouterError> {

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

}

```