Fluent::ExecUtil::Parser
# File lib/fluent/plugin/exec_util.rb, line 86 def call(io) @u = Fluent::Engine.msgpack_factory.unpacker(io) begin @u.each(&@on_message) rescue EOFError end end