Module: PubsubNotifier::Proxy::ClassMethods

Defined in:
lib/pubsub_notifier/proxy.rb

Instance Method Summary collapse

Instance Method Details

#pubsub ⇒ Object 



15
16
17
 
# File 'lib/pubsub_notifier/proxy.rb', line 15

def pubsub
  @_pubsub ||= ::PubsubNotifier::Pubsub.new
end

#subscribe(subscriber_name, options = {}) ⇒ Object 



8
9
10
11
12
13
 
# 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