Class: Fluent::TaggedCopyOutputChain

Inherits:
TaggedOutputChain show all
Defined in:
lib/fluent/plugin/out_tagged_copy.rb

Instance Method Summary collapse

Methods inherited from TaggedOutputChain

#initialize

Constructor Details

This class inherits a constructor from Fluent::TaggedOutputChain

Instance Method Details

#next ⇒ Object 



95
96
97
98
99
100
101
102
103
104
 
# File 'lib/fluent/plugin/out_tagged_copy.rb', line 95

def next
  if @array.length <= @offset
    return @chain.next
  end
  @offset += 1
  es = @array.length > @offset ? @es.dup : @es
  emit_tag = @tag_procs[@offset-1].call(@tag) # added
  result = @array[@offset-1].emit(emit_tag, es, self)
  result
end