Module: Fluent::ObjectBufferedOutput::BufferedEventStreamMixin

Includes:

Enumerable

Defined in:

lib/fluent/output.rb

Instance Method Summary

• #each(&block) ⇒ Object
• #repeatable? ⇒ Boolean
• #to_msgpack_stream ⇒ Object

Instance Method Details

#each(&block) ⇒ Object

# File 'lib/fluent/output.rb', line 469

def each(&block)
  msgpack_each(&block)
end

#repeatable? ⇒ Boolean

# File 'lib/fluent/output.rb', line 465

def repeatable?
  true
end

#to_msgpack_stream ⇒ Object

# File 'lib/fluent/output.rb', line 473

def to_msgpack_stream
  read
end