Remove irc stream task from iced stream which has backpressure

squidowl · Sep 12, 2024 · b816999 · b816999
1 parent 5dce561
commit b816999
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/data/src/stream.rs b/data/src/stream.rs
@@ -75,7 +75,9 @@ pub fn run(
 ) -> impl futures::Stream<Item = Update> {
     let (sender, receiver) = mpsc::unbounded();
 
-    let runner = stream::once(_run(server, proxy, sender)).map(|_| unreachable!());
+    // Spawn to unblock backend from iced stream which has backpressure
+    let runner = stream::once(async { tokio::spawn(_run(server, proxy, sender)).await })
+        .map(|_| unreachable!());
 
     stream::select(receiver, runner)
 }