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::MessagePackFactory.msgpack_unpacker(io) begin @u.each(&@on_message) rescue EOFError end end