Sha256: 3e81ca9e55caeff98215804c5afb694548a0d50121395baac44180c99369c0a5
Contents?: true
Size: 1.19 KB
Versions: 6
Compression:
Stored size: 1.19 KB
Contents
module HTTP2
# Basic event emitter implementation with support for persistent and
# one-time event callbacks.
#
module Emitter
# Subscribe to all future events for specified type.
#
# @param event [Symbol]
# @param block [Proc] callback function
def add_listener(event, &block)
fail ArgumentError, 'must provide callback' unless block_given?
listeners(event.to_sym).push block
end
alias_method :on, :add_listener
# Subscribe to next event (at most once) for specified type.
#
# @param event [Symbol]
# @param block [Proc] callback function
def once(event, &block)
add_listener(event) do |*args, &callback|
block.call(*args, &callback)
:delete
end
end
# Emit event with provided arguments.
#
# @param event [Symbol]
# @param args [Array] arguments to be passed to the callbacks
# @param block [Proc] callback function
def emit(event, *args, &block)
listeners(event).delete_if do |cb|
cb.call(*args, &block) == :delete
end
end
private
def listeners(event)
@listeners ||= Hash.new { |hash, key| hash[key] = [] }
@listeners[event]
end
end
end
Version data entries
6 entries across 6 versions & 2 rubygems