Class: Fluent::OneEventStream

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

Instance Method Summary collapse

Methods inherited from EventStream

#==, #empty?, #to_msgpack_stream, #to_msgpack_stream_forced_integer

Methods included from MessagePackFactory::Mixin

#msgpack_factory, #msgpack_packer, #msgpack_unpacker

Constructor Details

#initialize(time, record) ⇒ OneEventStream

Returns a new instance of OneEventStream.



74
75
76
77
 
# File 'lib/fluent/event.rb', line 74

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

Instance Method Details

#dup ⇒ Object 



79
80
81
 
# File 'lib/fluent/event.rb', line 79

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

#each(&block) ⇒ Object 



99
100
101
102
 
# File 'lib/fluent/event.rb', line 99

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

#repeatable? ⇒ Boolean

Returns:

  • (Boolean) 


87
88
89
 
# File 'lib/fluent/event.rb', line 87

def repeatable?
  true
end

#size ⇒ Object 



83
84
85
 
# File 'lib/fluent/event.rb', line 83

def size
  1
end

#slice(index, num) ⇒ Object 



91
92
93
94
95
96
97
 
# File 'lib/fluent/event.rb', line 91

def slice(index, num)
  if index > 0 || num == 0
    ArrayEventStream.new([])
  else
    self.dup
  end
end