Class: Fluent::ArrayEventStream

Inherits:
EventStream show all
Defined in:
lib/fluent/event.rb

Instance Method Summary collapse

Methods inherited from EventStream

#to_msgpack_stream

Constructor Details

#initialize(entries) ⇒ ArrayEventStream

Returns a new instance of ArrayEventStream.



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

def initialize(entries)
  @entries = entries
end

Instance Method Details

#each(&block) ⇒ Object 



71
72
73
74
 
# File 'lib/fluent/event.rb', line 71

def each(&block)
  @entries.each(&block)
  nil
end

#empty? ⇒ Boolean

Returns:

  • (Boolean) 


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

def empty?
  @entries.empty?
end

#repeatable? ⇒ Boolean

Returns:

  • (Boolean) 


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

def repeatable?
  true
end