We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6e9e021 commit 8d8de10Copy full SHA for 8d8de10
README.md
@@ -69,8 +69,11 @@ class BufferOverflowHandler
69
70
def flush(messages)
71
@buffer ||= []
72
- MessagePack::Unpacker.new.feed_each(messages) do |msg|
73
- @buffer << msg
+ messages.each do |tag, message|
+ unpacker = MessagePack::Unpacker.new(StringIO.new(message))
74
+ unpacker.each do |time, record|
75
+ @buffer << [tag, time, record]
76
+ end
77
end
78
79
0 commit comments