class Fluent::ArrayEventStream

EventStream from entries: Array of [time, record]

Use this class for many events data with a tag and its representation is [ [time, record], [time, record], .. ]

Public Class Methods

new(entries) click to toggle source
# File lib/fluent/event.rb, line 66
def initialize(entries)
  @entries = entries
end

Public Instance Methods

dup() click to toggle source
# File lib/fluent/event.rb, line 70
def dup
  entries = @entries.map { |entry| entry.dup } # @entries.map(:dup) doesn't work by ArgumentError
  ArrayEventStream.new(entries)
end
each(&block) click to toggle source
# File lib/fluent/event.rb, line 83
def each(&block)
  @entries.each(&block)
  nil
end
empty?() click to toggle source
# File lib/fluent/event.rb, line 79
def empty?
  @entries.empty?
end
repeatable?() click to toggle source
# File lib/fluent/event.rb, line 75
def repeatable?
  true
end