lib/wisper.rb in wisper-1.5.0 vs lib/wisper.rb in wisper-1.6.0
- old
+ new
@@ -24,18 +24,37 @@
def self.add_listener(listener, options = {})
warn "[DEPRECATION] `use Wisper.subscribe` instead of `Wisper.add_listener`"
self.subscribe(listener, options)
end
+ # Examples:
+ #
+ # Wisper.subscribe(AuditRecorder.new)
+ #
+ # Wisper.subscribe(AuditRecorder.new, StatsRecorder.new)
+ #
+ # Wisper.subscribe(AuditRecorder.new, on: 'order_created')
+ #
+ # Wisper.subscribe(AuditRecorder.new, scope: 'MyPublisher')
+ #
+ # Wisper.subscribe(AuditRecorder.new, StatsRecorder.new) do
+ # # ..
+ # end
+ #
def self.subscribe(*args, &block)
if block_given?
- TemporaryListeners.with(*args, &block)
+ TemporaryListeners.subscribe(*args, &block)
else
- options = args.last.is_a?(Hash) ? args.pop : {}
- args.each do |listener|
- GlobalListeners.add(listener, options)
- end
+ GlobalListeners.subscribe(*args)
end
+ end
+
+ def self.publisher
+ Publisher
+ end
+
+ def self.clear
+ GlobalListeners.clear
end
def self.configure
yield(configuration)
end