Open
Description
Docs don't say if the following code is correct or may produce unexpected results:
let update_receiver: tokio::sync::broadcast::Receiver;
let sock: axum::extract::ws::WebSocket;
let (mut ws_write, mut ws_read) = sock.split();
tokio::select! {
// Cancel-safe. https://docs.rs/tokio/1.43.0/tokio/sync/broadcast/struct.Receiver.html#cancel-safety
clientbound = update_receiver.recv() => {...}
// ??? https://docs.rs/axum/0.8.1/axum/extract/ws/struct.WebSocket.html#method.recv
serverbound = ws_read.recv() => {...}
}
Metadata
Metadata
Assignees
Labels
No labels