module EventMachine::SpecHelper

Constants

SpecTimeoutExceededError

Public Class Methods

included(cls) click to toggle source
# File lib/em-spec/rspec.rb, line 9
def self.included(cls)
  ::RSpec::Core::ExampleGroup.instance_eval "
  @@_em_default_time_to_finish = nil
  def self.default_timeout(timeout)
    @@_em_default_time_to_finish = timeout
  end
  "
end

Public Instance Methods

done() click to toggle source
# File lib/em-spec/rspec.rb, line 43
def done
  EM.next_tick{
    finish_em_spec_fiber
  }
end
em(time_to_run = @@_em_default_time_to_finish, &block) click to toggle source
# File lib/em-spec/rspec.rb, line 23
def em(time_to_run = @@_em_default_time_to_finish, &block)
  em_spec_exception = nil

  EM.run do
    timeout(time_to_run) if time_to_run
    @_em_spec_fiber = Fiber.new do
      begin
        block.call
      rescue Exception => em_spec_exception
        done
      end
      Fiber.yield
    end  

    @_em_spec_fiber.resume
  end

  raise em_spec_exception if em_spec_exception
end
timeout(time_to_run) click to toggle source
# File lib/em-spec/rspec.rb, line 18
def timeout(time_to_run)
  EM.cancel_timer(@_em_timer) if @_em_timer
  @_em_timer = EM.add_timer(time_to_run) { done; raise SpecTimeoutExceededError.new }
end

Private Instance Methods

finish_em_spec_fiber() click to toggle source
# File lib/em-spec/rspec.rb, line 51
def finish_em_spec_fiber
  EM.stop_event_loop if EM.reactor_running?
  @_em_spec_fiber.resume if @_em_spec_fiber.alive?
end