Class/Module Index [+]

Quicksearch

Fluent::MultiEventStream

Public Class Methods

new() click to toggle source
# File lib/fluent/event.rb, line 85
def initialize
  @time_array = []
  @record_array = []
end

Public Instance Methods

add(time, record) click to toggle source
# File lib/fluent/event.rb, line 90
def add(time, record)
  @time_array << time
  @record_array << record
end
each(&block) click to toggle source
# File lib/fluent/event.rb, line 103
def each(&block)
  time_array = @time_array
  record_array = @record_array
  for i in 0..time_array.length-1
    block.call(time_array[i], record_array[i])
  end
  nil
end
empty?() click to toggle source
# File lib/fluent/event.rb, line 99
def empty?
  @time_array.empty?
end
repeatable?() click to toggle source
# File lib/fluent/event.rb, line 95
def repeatable?
  true
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.