Sha256: 31c3095f39a95840d25f9d356439230116d466edb1e5d96fdc91387117142b99
Contents?: true
Size: 1.5 KB
Versions: 20
Compression:
Stored size: 1.5 KB
Contents
# frozen_string_literal: true
module Karafka
module Core
# Karafka instrumentation related shared components
module Instrumentation
# This manager allows us to register multiple callbacks into a hook that is suppose to support
# a single callback
class CallbacksManager
# @return [::Karafka::Core::Instrumentation::CallbacksManager]
def initialize
@callbacks = {}
end
# Invokes all the callbacks registered one after another
#
# @param args [Object] any args that should go to the callbacks
# @note We do not use `#each_value` here on purpose. With it being used, we cannot dispatch
# callbacks and add new at the same time. Since we don't know when and in what thread
# things are going to be added to the manager, we need to extract values into an array and
# run it. That way we can add new things the same time.
def call(*args)
@callbacks.values.each { |callback| callback.call(*args) }
end
# Adds a callback to the manager
#
# @param id [String] id of the callback (used when deleting it)
# @param callable [#call] object that responds to a `#call` method
def add(id, callable)
@callbacks[id] = callable
end
# Removes the callback from the manager
# @param id [String] id of the callback we want to remove
def delete(id)
@callbacks.delete(id)
end
end
end
end
end
Version data entries
20 entries across 20 versions & 1 rubygems