refactor stream_consumer

Co-authored-by: Carl Hörberg <carl@84codes.com>
cloudamqp · Jan 20, 2025 · c9ada3c · c9ada3c
1 parent cf274b9
commit c9ada3c
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/lavinmq/amqp/stream_consumer.cr b/src/lavinmq/amqp/stream_consumer.cr
@@ -46,9 +46,9 @@ module LavinMQ
           # noop
         else raise LavinMQ::Error::PreconditionFailed.new("x-stream-filter-value must be a string")
         end
-        case frame.arguments["x-stream-match-unfiltered"]?
+        case match_unfiltered = frame.arguments["x-stream-match-unfiltered"]?
         when Bool
-          @match_unfiltered = frame.arguments["x-stream-match-unfiltered"].as(Bool)
+          @match_unfiltered = match_unfiltered
         when Nil
           # noop
         else raise LavinMQ::Error::PreconditionFailed.new("x-stream-match-unfiltered must be a boolean")