class Fluent::Test::Driver::TestEventRouter

def emit(tag, time, record)
  @driver.emit_event_stream(tag, OneEventStream.new(time, record))
end