Contents

module Faye
  module Timeouts
    def add_timeout(name, delay, &block)
      Engine.ensure_reactor_running!
      @timeouts ||= {}
      return if @timeouts.has_key?(name)
      @timeouts[name] = EventMachine.add_timer(delay) do
        @timeouts.delete(name)
        block.call
      end
    end

    def remove_timeout(name)
      @timeouts ||= {}
      timeout = @timeouts[name]
      return if timeout.nil?
      EventMachine.cancel_timer(timeout)
      @timeouts.delete(name)
    end
  end
end

Version data entries

4 entries across 4 versions & 2 rubygems

Version	Path
faye-0.8.11	lib/faye/mixins/timeouts.rb
faye-1.0.0	lib/faye/mixins/timeouts.rb
face-faye-0.8.9	lib/faye/mixins/timeouts.rb
faye-0.8.9	lib/faye/mixins/timeouts.rb