class Fluent::OneEventStream

Public Class Methods

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

Public Instance Methods

dup() click to toggle source
# File lib/fluent/event.rb, line 85
def dup
  OneEventStream.new(@time, @record.dup)
end
each(unpacker: nil, &block) click to toggle source
# File lib/fluent/event.rb, line 109
def each(unpacker: nil, &block)
  block.call(@time, @record)
  nil
end
empty?() click to toggle source
# File lib/fluent/event.rb, line 89
def empty?
  false
end
repeatable?() click to toggle source
# File lib/fluent/event.rb, line 97
def repeatable?
  true
end
size() click to toggle source
# File lib/fluent/event.rb, line 93
def size
  1
end
slice(index, num) click to toggle source
# File lib/fluent/event.rb, line 101
def slice(index, num)
  if index > 0 || num == 0
    ArrayEventStream.new([])
  else
    self.dup
  end
end