module Fluent::ObjectBufferedOutput::BufferedEventStreamMixin

Public Instance Methods

each(&block) click to toggle source
# File lib/fluent/output.rb, line 452
def each(&block)
  msgpack_each(&block)
end
repeatable?() click to toggle source
# File lib/fluent/output.rb, line 448
def repeatable?
  true
end
to_msgpack_stream() click to toggle source
# File lib/fluent/output.rb, line 456
def to_msgpack_stream
  read
end