module Fluent::Test::InputTestDriver::EmitStreamWrapper

def emit_stream(tag, es)
  @emit_stream_callee.call(tag, es)
end

def emit_stream_callee=(method)
  @emit_stream_callee = method
end