Class: Fluent::OneEventStream

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

Instance Method Summary collapse

Methods inherited from EventStream

#to_msgpack_stream

Constructor Details

#initialize(time, record) ⇒ OneEventStream

Returns a new instance of OneEventStream.



42
43
44
45
 
# File 'lib/fluent/event.rb', line 42

def initialize(time, record)
  @time = time
  @record = record
end

Instance Method Details

#dup ⇒ Object 



47
48
49
 
# File 'lib/fluent/event.rb', line 47

def dup
  OneEventStream.new(@time, @record.dup)
end

#each(&block) ⇒ Object 



55
56
57
58
 
# File 'lib/fluent/event.rb', line 55

def each(&block)
  block.call(@time, @record)
  nil
end

#repeatable? ⇒ Boolean

Returns:

  • (Boolean) 


51
52
53
 
# File 'lib/fluent/event.rb', line 51

def repeatable?
  true
end