module Fluent::Test::InputTestDriver::EmitStreamWrapper

Public Instance Methods

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