fixup! StreamQueue: only unmap unused segments

cloudamqp · Aug 9, 2023 · fb44bff · fb44bff
1 parent 21e64b1
commit fb44bff
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/lavinmq/queue/stream_queue.cr b/src/lavinmq/queue/stream_queue.cr
@@ -156,7 +156,7 @@ module LavinMQ
     end
 
     private def unmap_unused_segments
-      used_segments = @consumers_lock.synchronize { @consumers.map &.segment }
+      used_segments = @consumers_lock.synchronize { @consumers.map &.as(Client::Channel::StreamConsumer).segment }
       @msg_store_lock.synchronize do
         stream_queue_msg_store.unmap_segments(except: used_segments)
       end