# File lib/fluent/test/input_test.rb, line 107 def emit_stream(tag, es) @emit_stream_callee.call(tag, es) end
# File lib/fluent/test/input_test.rb, line 104 def emit_stream_callee=(method) @emit_stream_callee = method end