class ThinkingSphinx::RealTime::Processor

Attributes

indices[R]

Public Class Methods

call(indices, &block) click to toggle source
# File lib/thinking_sphinx/real_time/processor.rb, line 4
def self.call(indices, &block)
  new(indices).call(&block)
end
new(indices) click to toggle source
# File lib/thinking_sphinx/real_time/processor.rb, line 8
def initialize(indices)
  @indices = indices
end

Public Instance Methods

call(&block) click to toggle source
# File lib/thinking_sphinx/real_time/processor.rb, line 12
def call(&block)
  subscribe_to_progress

  indices.each do |index|
    ThinkingSphinx::RealTime.populator.populate index

    block.call
  end
end

Private Instance Methods

command() click to toggle source
# File lib/thinking_sphinx/real_time/processor.rb, line 26
def command
  ThinkingSphinx::Commander.call(
    command, configuration, options, stream
  )
end
subscribe_to_progress() click to toggle source
# File lib/thinking_sphinx/real_time/processor.rb, line 32
def subscribe_to_progress
  ThinkingSphinx::Subscribers::PopulatorSubscriber.
    attach_to 'thinking_sphinx.real_time'
end