fix error handling in consumer task

feschber · Jan 23, 2024 · 82926d8 · 82926d8
1 parent 006831b
commit 82926d8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/server/consumer_task.rs b/src/server/consumer_task.rs
@@ -54,7 +54,9 @@ pub fn new(
                         None => break,
                     }
                 }
-                _ = consumer.dispatch() => { }
+                res = consumer.dispatch() => {
+                    res?;
+                }
             }
         }