Sha256: 43d833d4b47693882dbb029d3a2b58ff04497d7eae6e8c3d6bfba778d77a7b84
Contents?: true
Size: 623 Bytes
Versions: 28
Compression:
Stored size: 623 Bytes
Contents
# frozen_string_literal: true
module Karafka
module Connection
# Abstraction layer around listeners batch.
class ListenersBatch
include Enumerable
# @param jobs_queue [JobsQueue]
# @return [ListenersBatch]
def initialize(jobs_queue)
@batch = App.subscription_groups.map do |subscription_group|
Connection::Listener.new(subscription_group, jobs_queue)
end
end
# Iterates over available listeners and yields each listener
# @param block [Proc] block we want to run
def each(&block)
@batch.each(&block)
end
end
end
end
Version data entries
28 entries across 28 versions & 1 rubygems