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