# File lib/fluent/test/driver/test_event_router.rb, line 23 def initialize(driver) @driver = driver end
# File lib/fluent/test/driver/test_event_router.rb, line 27 def emit(tag, time, record) @driver.emit_event_stream(tag, OneEventStream.new(time, record)) end
# File lib/fluent/test/driver/test_event_router.rb, line 31 def emit_array(tag, array) @driver.emit_event_stream(tag, ArrayEventStream.new(array)) end
# File lib/fluent/test/driver/test_event_router.rb, line 39 def emit_error_event(tag, time, record, error) @driver.emit_error_event(tag, time, record, error) end
# File lib/fluent/test/driver/test_event_router.rb, line 35 def emit_stream(tag, es) @driver.emit_event_stream(tag, es) end