class Fluent::Test::Driver::TestEventRouter

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

def emit_array(tag, array)
  @driver.emit_event_stream(tag, ArrayEventStream.new(array))
end

def emit_error_event(tag, time, record, error)
  @driver.emit_error_event(tag, time, record, error)
end

def emit_stream(tag, es)
  @driver.emit_event_stream(tag, es)
end

def initialize(driver)
  @driver = driver
end