Module: Fluent::Test::InputTestDriver::EmitStreamWrapper

Defined in:: lib/fluent/test/input_test.rb

Instance Method Summary collapse

Instance Method Details

#emit_stream(tag, es) ⇒ `Object`



107
108
109

# 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) ⇒ `Object`



104
105
106

# File 'lib/fluent/test/input_test.rb', line 104

def emit_stream_callee=(method)
  @emit_stream_callee = method
end