no need to fuse message_rx.next() since message_rx is already stream-fused

jcdyer · jcdyer · commit 35b2083d7d15 · 2025-01-24T11:40:36.000-05:00
diff --git a/src/listen/websocket.rs b/src/listen/websocket.rs
@@ -567,7 +567,7 @@ async fn run_worker(
                     }
                 }
             }
-            message = message_rx.next().fuse() => {
+            message = message_rx.next() => {
                 // eprintln!("<worker> received message: {message:?}, {is_open:?}");
                 if is_open {
                     match message {

Original file line number	Diff line number	Diff line change
`@@ -567,7 +567,7 @@ async fn run_worker(`
`567`	`567`	`}`
`568`	`568`	`}`
`569`	`569`	`}`
`570`		`- message = message_rx.next().fuse() => {`
	`570`	`+ message = message_rx.next() => {`
`571`	`571`	`// eprintln!("<worker> received message: {message:?}, {is_open:?}");`
`572`	`572`	`if is_open {`
`573`	`573`	`match message {`