From 82926d82725a6b52dbe67b68294846a741ef9bc6 Mon Sep 17 00:00:00 2001 From: Ferdinand Schober Date: Tue, 23 Jan 2024 20:47:29 +0100 Subject: [PATCH] fix error handling in consumer task --- src/server/consumer_task.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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?; + } } }