class Processor::Thread
Attributes
runner[R]
Public Class Methods
new(data_processor, *observers)
click to toggle source
# File lib/processor/thread.rb, line 8 def initialize(data_processor, *observers) @runner = Runner.new EventProcessor.new(data_processor, observers) end
Public Instance Methods
run_as(&process_runner)
click to toggle source
# File lib/processor/thread.rb, line 12 def run_as(&process_runner) runner.run process_runner end
run_in_threads(number_of_threads = 2)
click to toggle source
# File lib/processor/thread.rb, line 20 def run_in_threads(number_of_threads = 2) runner.run ProcessRunner::Threads.new number_of_threads end
run_successive()
click to toggle source
# File lib/processor/thread.rb, line 16 def run_successive runner.run ProcessRunner::Successive.new end