diff --git a/src/redis_pubsub.rs b/src/redis_pubsub.rs
index 8b41886..26a41bd 100644
--- a/src/redis_pubsub.rs
+++ b/src/redis_pubsub.rs
@@ -45,7 +45,7 @@ fn handle_redis_inner(
                 },
                 Err(flume::TryRecvError::Empty) => break,
                 Err(flume::TryRecvError::Disconnected) => return Ok(()),
-            }
+            };
         }
 
         if let Some(msg) = match pubsub.get_message() {