# File lib/fluent/test/output_test.rb, line 37 def initialize(klass, tag='test', &block) super(klass, &block) @tag = tag end
# File lib/fluent/test/output_test.rb, line 44 def emit(record, time=Engine.now) es = OneEventStream.new(time, record) @instance.emit_events(@tag, es) end