From a8144e751b34ff6edb832405910dca2c1bd5b24a Mon Sep 17 00:00:00 2001 From: okkez Date: Tue, 23 Feb 2016 17:33:23 +0900 Subject: [PATCH] Update README.md to follow previous change --- README.md | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/README.md b/README.md index e7f9df3..4fd862d 100644 --- a/README.md +++ b/README.md @@ -152,8 +152,11 @@ class BufferOverflowHandler def flush(messages) @buffer ||= [] - MessagePack::Unpacker.new.feed_each(messages) do |msg| - @buffer << msg + messages.each do |tag, message| + unpacker = MessagePack::Unpacker.new(StringIO.new(message)) + unpacker.each do |time, record| + @buffer << [tag, time, record] + end end end end