Function echo_ws

websockets/echo-actorless/src/main.rs:34–41

Handshake and start basic WebSocket handler. This example is just for simple demonstration. In reality, you likely want to include some handling of heartbeats for connection health tracking to free up server resources when connections die or network issues arise.

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

/// some handling of heartbeats for connection health tracking to free up server resources when
/// connections die or network issues arise.
async fn echo_ws(req: HttpRequest, stream: web::Payload) -> Result<HttpResponse, Error> {
    let (res, session, msg_stream) = actix_ws::handle(&req, stream)?;

    // spawn websocket handler (and don't await it) so that the response is returned immediately
    rt::spawn(handler::echo_ws(session, msg_stream));

    Ok(res)
}

/// Send message to clients connected to broadcast WebSocket.
async fn send_to_broadcast_ws(