# File lib/amq/client/async/callbacks.rb, line 32 def clear_callbacks(event) @callbacks[event].clear if @callbacks[event] end
# File lib/amq/client/async/callbacks.rb, line 15 def define_callback(event, callable = nil, &block) f = (callable || block) @callbacks[event] ||= [] @callbacks[event] << f if f self end
# File lib/amq/client/async/callbacks.rb, line 37 def exec_callback(name, *args, &block) list = Array(@callbacks[name]) if list.any? list.each { |c| c.call(*args, &block) } end end
# File lib/amq/client/async/callbacks.rb, line 44 def exec_callback_once(name, *args, &block) list = (@callbacks.delete(name) || Array.new) if list.any? list.each { |c| c.call(*args, &block) } end end
# File lib/amq/client/async/callbacks.rb, line 58 def exec_callback_once_yielding_self(name, *args, &block) list = (@callbacks.delete(name) || Array.new) if list.any? list.each { |c| c.call(self, *args, &block) } end end
# File lib/amq/client/async/callbacks.rb, line 51 def exec_callback_yielding_self(name, *args, &block) list = Array(@callbacks[name]) if list.any? list.each { |c| c.call(self, *args, &block) } end end
# File lib/amq/client/async/callbacks.rb, line 66 def has_callback?(name) @callbacks[name] && !@callbacks[name].empty? end
Generated with the Darkfish Rdoc Generator 2.