Contents

module SearchKit
  # This file houses the polling loop of the Event service.
  #
  class Polling
    autoload :Process, 'search_kit/polling/process'

    def self.perform(channel, &block)
      new(channel, &block).perform
    end

    attr_reader :block, :channel

    def initialize(channel, &block)
      @block   = block
      @channel = channel
    end

    def perform
      loop do
        process_queue
        sleep 1
      end
    end

    def process_queue
      SearchKit::Polling::Process.perform(channel, &block)
    end

  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
search-kit-0.0.10	lib/search_kit/polling.rb
search-kit-0.0.9	lib/search_kit/polling.rb
search-kit-0.0.8	lib/search_kit/polling.rb
search-kit-0.0.7	lib/search_kit/polling.rb
search-kit-0.0.6	lib/search_kit/polling.rb
search-kit-0.0.5	lib/search_kit/polling.rb
search-kit-0.0.4	lib/search_kit/polling.rb
search-kit-0.0.3	lib/search_kit/polling.rb