module ParallelBatchApi::Processor

Public Instance Methods

parallel_process(env) click to toggle source
# File lib/parallel_batch_api/processor.rb, line 8
def parallel_process(env)
  Parallel.map(requests(env), in_threads: thread_size) do |item|
    ActiveRecord::Base.connection_pool.with_connection do
      e = env.deep_dup
      rack = ParallelBatchApi::RackProcessor.new(e, item, @app)
      rack.process
    end
  end
end
process(env) click to toggle source
# File lib/parallel_batch_api/processor.rb, line 4
def process(env)
  build_response(parallel_process(env.deep_dup))
end
requests(env) click to toggle source
# File lib/parallel_batch_api/processor.rb, line 18
def requests(env)
  build_requests(env)
end
thread_size() click to toggle source
# File lib/parallel_batch_api/processor.rb, line 22
def thread_size
  ParallelBatchApi.thread || 1
end