Stop log streamed bytes loop (#912)

cloudamqp · Jan 16, 2025 · 2c94ffa · 2c94ffa
1 parent d46c3b8
commit 2c94ffa
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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