Method handle_ws_msg

websockets/echo/src/server.rs:43–76

(
        &self,
        msg: AggregatedMessage,
        state: &mut (Instant, actix_ws::Session),
        myself: ActorRef<WsMessage>,
    )

    }

    async fn handle_ws_msg(
        &self,
        msg: AggregatedMessage,
        state: &mut (Instant, actix_ws::Session),
        myself: ActorRef<WsMessage>,
    ) -> Result<(), ActorProcessingErr> {
        println!("WS: {msg:?}");

        match msg {
            AggregatedMessage::Ping(msg) => {
                state.0 = Instant::now();
                state.1.pong(&msg).await?;
            }

            AggregatedMessage::Pong(_) => {
                state.0 = Instant::now();
            }

            AggregatedMessage::Text(text) => {
                state.1.text(text).await?;
            }

            AggregatedMessage::Binary(bin) => {
                state.1.binary(bin).await?;
            }

            AggregatedMessage::Close(reason) => {
                let _ = state.1.clone().close(reason).await;
                myself.stop(None);
            }
        };

        Ok(())
    }
}

impl ractor::Actor for MyWebSocket {