github/wasm-pong
1
0
Fork 0
mirror of https://github.com/thilo-behnke/wasm-pong.git synced 2026-07-13 19:49:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

send message to websocket

Browse Source
This commit is contained in:
Thilo Behnke
2022-06-05 15:45:33 +02:00
parent 7a8bb5ed7e
commit 9fabef3b9d
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/src/http.rs
View File

@@ -157,7 +157,15 @@ async fn serve_websocket(websocket_session: WebSocketSession, websocket: HyperWe
println!("Ready to read messages from kafka: {:?}", websocket_session_write_copy);
loop {
let messages = event_reader.read_from_session();
if let Err(_) = messages {
eprintln!("Failed to read messages from kafka for session: {:?}", websocket_session_write_copy);
continue;
}
println!("Read messages for websocket_session {:?} from consumer: {:?}", websocket_session_write_copy, messages);
let messages = messages.unwrap();
let json = serde_json::to_string(&messages).unwrap();
let message = Message::from(json);
websocket_writer.send(message);
}
});
Ok(())