Module EventMachineConcurrencyHelpers

# File actioncable/test/test_helper.rb, line 34
def run_in_eventmachine
  failure = nil
  EM.run do
    begin
      yield
    rescue => ex
      failure = ex
    ensure
      wait_for_async
      EM.stop if EM.reactor_running?
    end
  end
  raise failure if failure
end

# File actioncable/test/test_helper.rb, line 30
def wait_for_async
  EM.run_deferred_callbacks
end