Methods

Class/Module Index [+]

Quicksearch

Fluent::ExecFilterOutput::MessagePackParser

Public Instance Methods

call(io) click to toggle source
# File lib/fluent/plugin/out_exec_filter.rb, line 430
def call(io)
  @u = MessagePack::Unpacker.new(io)
  begin
    @u.each(&@on_message)
  rescue EOFError
  end
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.