# File lib/fluent/plugin/out_copy.rb, line 28 def process(tag, es) unless es.repeatable? m = Fluent::MultiEventStream.new es.each {|time,record| m.add(time, record) } es = m end outputs.each do |output| output.emit_events(tag, @deep_copy ? es.dup : es) end end