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