We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 6f15474 commit 2913653Copy full SHA for 2913653
1 file changed
src/sacp/src/session.rs
@@ -680,7 +680,7 @@ where
680
// Step 3: Drain any messages that were already queued and forward to client.
681
// These messages arrived before we dropped the handler but haven't been
682
// consumed yet. We must forward them to maintain message ordering.
683
- while let Some(message) = update_rx.try_next().ok().flatten() {
+ while let Some(message) = update_rx.try_recv().ok() {
684
match message {
685
SessionMessage::SessionMessage(dispatch) => {
686
// Forward the message to the client
0 commit comments