class Fluent::Compat::ExecUtil::MessagePackParser

Public Instance Methods

call(io) click to toggle source
# File lib/fluent/compat/exec_util.rb, line 87
def call(io)
  @u = Fluent::Engine.msgpack_factory.unpacker(io)
  begin
    @u.each(&@on_message)
  rescue EOFError
  end
end