Sha256: d3266b0a99343aa6988b949de43e37029eb42973af77e6e064e6f945fa99cfe9
Contents?: true
Size: 555 Bytes
Versions: 7
Compression:
Stored size: 555 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Processing
# Abstraction layer around workers batch.
class WorkersBatch
include Enumerable
# @param jobs_queue [JobsQueue]
# @return [WorkersBatch]
def initialize(jobs_queue)
@batch = Array.new(App.config.concurrency) { Processing::Worker.new(jobs_queue) }
end
# Iterates over available workers and yields each worker
# @param block [Proc] block we want to run
def each(&block)
@batch.each(&block)
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems