diff options
Diffstat (limited to 'src/spectate')
| -rw-r--r-- | src/spectate/server.rs | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/spectate/server.rs b/src/spectate/server.rs index fdcc815..7f8c90a 100644 --- a/src/spectate/server.rs +++ b/src/spectate/server.rs @@ -5,7 +5,7 @@ use axum::{ extract::{ self, connect_info::ConnectInfo, - ws::{Message, WebSocket, WebSocketUpgrade}, + ws::{Message, Utf8Bytes, WebSocket, WebSocketUpgrade}, }, http::HeaderMap, response::{Html, IntoResponse}, @@ -217,7 +217,7 @@ async fn handle_socket( let past = state.past_events.read().await.clone(); for p in past { socket - .send(Message::Text(serde_json::to_string(&p)?)) + .send(Message::Text(Utf8Bytes::from(serde_json::to_string(&p)?))) .await?; } let mut live = state.events.subscribe(); @@ -229,7 +229,7 @@ async fn handle_socket( } event = live.recv() => { socket - .send(Message::Text(serde_json::to_string(&event?)?)) + .send(Message::Text(Utf8Bytes::from( serde_json::to_string(&event?)?))) .await?; } } |