Sha256: 82b7526ce370ffdbfa1f5bdee126d6d2084734f5ff3e11cf7e64e26d4fbfd3f1
Contents?: true
Size: 920 Bytes
Versions: 1
Compression:
Stored size: 920 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.flat_map do |_consumer_group, subscription_groups| consumer_group_status = Connection::ConsumerGroupStatus.new( subscription_groups.size ) subscription_groups.map do |subscription_group| Connection::Listener.new( consumer_group_status, subscription_group, jobs_queue ) end 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
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
karafka-2.0.18 | lib/karafka/connection/listeners_batch.rb |