Module: Fluent::Compat::BufferedEventStreamMixin

Includes:
Enumerable
Defined in:
lib/fluent/compat/output.rb

Instance Method Summary collapse

Instance Method Details

#each(&block) ⇒ Object 



59
60
61
 
# File 'lib/fluent/compat/output.rb', line 59

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

#key ⇒ Object 



67
68
69
 
# File 'lib/fluent/compat/output.rb', line 67

def key
  metadata.tag
end

#repeatable? ⇒ Boolean

Returns:

  • (Boolean) 


55
56
57
 
# File 'lib/fluent/compat/output.rb', line 55

def repeatable?
  true
end

#to_msgpack_stream ⇒ Object 



63
64
65
 
# File 'lib/fluent/compat/output.rb', line 63

def to_msgpack_stream
  read
end