diff --git a/src/server/consumer_task.rs b/src/server/consumer_task.rs
index fc67a41..96e7eaa 100644
--- 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?;
+                }
             }
         }