# 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
# 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