Actix WS

websockets for the Actix Runtime without actors

Usage

```toml

Cargo.toml

anyhow = "1.0" actix-web = "4.0.1" actix-ws = "0.2.0" ```

```rust // main.rs use actixweb::{middleware::Logger, web, App, Error, HttpRequest, HttpResponse, HttpServer}; use actixws::Message;

async fn ws(req: HttpRequest, body: web::Payload) -> Result { let (response, mut session, mut msgstream) = actixws::handle(&req, body)?;

actix_rt::spawn(async move {
    while let Some(Ok(msg)) = msg_stream.next().await {
        match msg {
            Message::Ping(bytes) => {
                if session.pong(&bytes).await.is_err() {
                    return;
                }
            }
            Message::Text(s) => println!("Got text, {}", s),
            _ => break,
        }
    }

    let _ = session.close(None).await;
});

Ok(response)

}

[actix_web::main]

async fn main() -> Result<(), anyhow::Error> { HttpServer::new(move || { App::new() .wrap(Logger::default()) .route("/ws", web::get().to(ws)) }) .bind("127.0.0.1:8080")? .run() .await?;

Ok(())

} ```

License

This project is licensed under either of

at your option.