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