# frozen_string_literal: true module HTTPX module Callbacks def on(type, &action) callbacks(type) << action end def once(type, &block) on(type) do |*args, &callback| block.call(*args, &callback) :delete end end def only(type, &block) callbacks(type).clear on(type, &block) end def emit(type, *args) callbacks(type).delete_if { |pr| :delete == pr[*args] } # rubocop:disable Style/YodaCondition end protected def callbacks_for?(type) @callbacks.key?(type) && !@callbacks[type].empty? end def callbacks(type = nil) return @callbacks unless type @callbacks ||= Hash.new { |h, k| h[k] = [] } @callbacks[type] end end end