module Fluent::Compat::BufferedEventStreamMixin

Public Instance Methods

each(&block) click to toggle source
# File lib/fluent/compat/output.rb, line 56
def each(&block)
  msgpack_each(&block)
end
key() click to toggle source
# File lib/fluent/compat/output.rb, line 64
def key
  metadata.tag
end
repeatable?() click to toggle source
# File lib/fluent/compat/output.rb, line 52
def repeatable?
  true
end
to_msgpack_stream() click to toggle source
# File lib/fluent/compat/output.rb, line 60
def to_msgpack_stream
  read
end