Update README.md to follow previous change

fluent · Sep 27, 2018 · a8144e7 · a8144e7
1 parent 4f98038
commit a8144e7
Showing 1 changed file with 5 additions and 2 deletions.
diff --git 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