From d01f12ecceae6d4709c687c50f34bf35211dfc87 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Jon=20B=C3=B6rjesson?= <jon@spuun.se>
Date: Thu, 16 Jan 2025 09:13:38 +0100
Subject: [PATCH] Stop log streamed bytes loop

---
 src/lavinmq/clustering/client.cr | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/lavinmq/clustering/client.cr b/src/lavinmq/clustering/client.cr
index b7e13ef02b..95b5e90b58 100644
--- a/src/lavinmq/clustering/client.cr
+++ b/src/lavinmq/clustering/client.cr
@@ -254,6 +254,7 @@ module LavinMQ
       private def log_streamed_bytes_loop
         loop do
           sleep 30.seconds
+          break if @closed
           Log.info { "Total streamed bytes: #{@streamed_bytes}" }
         end
       end