Skip to content

Commit

Permalink
refactor
Browse files Browse the repository at this point in the history
Co-authored-by: Carl Hörberg <[email protected]>
  • Loading branch information
viktorerlingsson and carlhoerberg authored Jan 21, 2025
1 parent 0b126a2 commit cb4a6d1
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/lavinmq/amqp/stream_consumer.cr
Original file line number Diff line number Diff line change
Expand Up @@ -9,8 +9,8 @@ module LavinMQ
property segment : UInt32
property pos : UInt32
getter requeued = Deque(SegmentPosition).new
@filter : Array(String) = Array(String).new
@match_unfiltered : Bool = false
@filter = Array(String).new
@match_unfiltered = false

def initialize(@channel : Client::Channel, @queue : StreamQueue, frame : AMQP::Frame::Basic::Consume)
validate_preconditions(frame)
Expand Down

0 comments on commit cb4a6d1

Please sign in to comment.