class Fluent::BufferChunk

def empty? 

def empty?
  size == 0
end

def initialize(key) 

def initialize(key)
  super()
  @key = key
end

def msgpack_each(&block) 

def msgpack_each(&block)
  open {|io|
    u = MessagePack::Unpacker.new(io)
    begin
      u.each(&block)
    rescue EOFError
    end
  }
end

def write_to(io) 

def write_to(io)
  open {|i|
    FileUtils.copy_stream(i, io)
  }
end