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