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