Skip to content

Commit

Permalink
add comments
Browse files Browse the repository at this point in the history
  • Loading branch information
viktorerlingsson committed Jan 10, 2025
1 parent 8637d8c commit 8faff93
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions src/lavinmq/amqp/stream_consumer.cr
Original file line number Diff line number Diff line change
@@ -43,12 +43,14 @@ module LavinMQ
when String
@filter = frame.arguments["x-stream-filter-value"].to_s.split(",")
when Nil
# noop
else raise LavinMQ::Error::PreconditionFailed.new("x-stream-filter-value must be a string")
end
case frame.arguments["x-stream-match-unfiltered"]?
when Bool
@match_unfiltered = frame.arguments["x-stream-match-unfiltered"].as(Bool)
when Nil
# noop
else raise LavinMQ::Error::PreconditionFailed.new("x-stream-match-unfiltered must be a boolean")
end
end

0 comments on commit 8faff93

Please sign in to comment.