class Fluent::Compat::OutputChain
Private Class Methods
new(array, tag, es, chain=NullOutputChain.instance)
click to toggle source
# File lib/fluent/compat/output_chain.rb, line 30 def initialize(array, tag, es, chain=NullOutputChain.instance) @array = array @tag = tag @es = es @offset = 0 @chain = chain end
Private Instance Methods
next()
click to toggle source
# File lib/fluent/compat/output_chain.rb, line 38 def next if @array.length <= @offset return @chain.next end @offset += 1 @array[@offset-1].emit_events(@tag, @es) self.next end