Contents

class RestCore::Timeout::EventMachineTimer < ::EventMachine::Timer
  attr_accessor :timeout, :error

  def initialize timeout, error, &block
    super(timeout, &block) if block_given?
    self.timeout = timeout
    self.error   = error
    @canceled    = false
  end

  def on_timeout &block
    send(:initialize, timeout, error, &block)
  end

  def cancel
    super
    @canceled = true
  end

  def canceled?
    @canceled
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
rest-core-1.0.3	lib/rest-core/middleware/timeout/eventmachine_timer.rb
rest-core-1.0.2	lib/rest-core/middleware/timeout/eventmachine_timer.rb