class Fluent::ExecFilterOutput::MessagePackParser

def call(io)
  @u = MessagePack::Unpacker.new(io)
  begin
    @u.each(&@on_message)
  rescue EOFError
  end
end