Method: Fluent::Test::Driver::BaseOwner#run

Defined in:
lib/fluent/test/driver/base_owner.rb

#run(expect_emits: nil, expect_records: nil, timeout: nil, start: true, shutdown: true, &block) ⇒ Object 



122
123
124
125
126
127
128
129
130
131
 
# File 'lib/fluent/test/driver/base_owner.rb', line 122

def run(expect_emits: nil, expect_records: nil, timeout: nil, start: true, shutdown: true, &block)
  if expect_emits
    @run_post_conditions << ->(){ emit_count >= expect_emits }
  end
  if expect_records
    @run_post_conditions << ->(){ record_count >= expect_records }
  end

  super(timeout: timeout, start: start, shutdown: shutdown, &block)
end