module PubsubNotifier::Proxy::ClassMethods
Public Instance Methods
pubsub()
click to toggle source
# File lib/pubsub_notifier/proxy.rb, line 15 def pubsub @_pubsub ||= ::PubsubNotifier::Pubsub.new end
subscribe(subscriber_name, options = {})
click to toggle source
# File lib/pubsub_notifier/proxy.rb, line 8 def subscribe(subscriber_name, options = {}) subscriber = subscriber_name.to_s.constantize broadcaster = (options.delete(:async) ? broadcasters[:async] : nil) || broadcasters[:default] broadcaster.configure(options) if broadcaster.respond_to?(:configure) pubsub.subscribe(subscriber, broadcaster: broadcaster) end
Private Instance Methods
broadcasters()
click to toggle source
# File lib/pubsub_notifier/proxy.rb, line 21 def broadcasters Wisper.configuration.broadcasters end