Contents

# encoding: utf-8

module HTTPkit
  class Promise < ::Promise
    def wait
      fiber  = Fiber.current
      resume = proc { fiber.resume }
      self.then(resume, resume)

      Fiber.yield
    end

    private

    def defer
      EM.next_tick { yield } if EM.reactor_running?
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
httpkit-0.6.0	lib/httpkit/promise.rb
httpkit-0.6.0.pre.5	lib/httpkit/promise.rb
httpkit-0.6.0.pre.3	lib/httpkit/promise.rb