Contents

# 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.call(*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

Version data entries

33 entries across 33 versions & 1 rubygems

Version	Path
httpx-0.19.1	lib/httpx/callbacks.rb
httpx-0.19.0	lib/httpx/callbacks.rb
httpx-0.18.7	lib/httpx/callbacks.rb
httpx-0.18.6	lib/httpx/callbacks.rb
httpx-0.18.5	lib/httpx/callbacks.rb
httpx-0.18.4	lib/httpx/callbacks.rb
httpx-0.18.3	lib/httpx/callbacks.rb
httpx-0.18.2	lib/httpx/callbacks.rb
httpx-0.18.1	lib/httpx/callbacks.rb
httpx-0.18.0	lib/httpx/callbacks.rb
httpx-0.17.0	lib/httpx/callbacks.rb
httpx-0.16.1	lib/httpx/callbacks.rb
httpx-0.16.0	lib/httpx/callbacks.rb