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`



106
107
108

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

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

#emit_stream_callee=(method) ⇒ `Object`



103
104
105

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

def emit_stream_callee=(method)
  @emit_stream_callee = method
end