Function echo_ws

websockets/echo/src/main.rs:17–31

WebSocket handshake and start `MyWebSocket` actor.

(req: HttpRequest, stream: web::Payload)

/// WebSocket handshake and start `MyWebSocket` actor.
async fn echo_ws(req: HttpRequest, stream: web::Payload) -> Result<HttpResponse, Error> {
    let (res, session, stream) = actix_ws::handle(&req, stream)?;

    let (actor, _handle) = Actor::spawn(None, MyWebSocket, session).await.unwrap();

    actix_web::rt::spawn(async move {
        let mut stream = stream.aggregate_continuations();

        while let Some(Ok(msg)) = stream.recv().await {
            actor.send_message(WsMessage::Ws(msg)).unwrap();
        }
    });

    Ok(res)
}

// the actor-based WebSocket examples REQUIRE `actix_web::main` for actor support
#[actix_web::main]