Skip to content

Commit 469a29e

Browse files
committed
Update README.md to follow previous change
1 parent 9eb1ec2 commit 469a29e

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

README.md

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -139,8 +139,11 @@ class BufferOverflowHandler
139139
140140
def flush(messages)
141141
@buffer ||= []
142-
MessagePack::Unpacker.new.feed_each(messages) do |msg|
143-
@buffer << msg
142+
messages.each do |tag, message|
143+
unpacker = MessagePack::Unpacker.new(StringIO.new(message))
144+
unpacker.each do |time, record|
145+
@buffer << [tag, time, record]
146+
end
144147
end
145148
end
146149
end

0 commit comments

Comments
 (0)