class Fluent::Test::OutputTestDriver

def emit(record, time=Engine.now)
  es = OneEventStream.new(time, record)
  @instance.emit_events(@tag, es)
end

def initialize(klass, tag='test', &block)
  super(klass, &block)
  @tag = tag
end