class Downstream::Stateless::Pubsub
Public Instance Methods
publish(identifier, event)
click to toggle source
# File lib/downstream/pubsub_adapters/stateless/pubsub.rb, line 21 def publish(identifier, event) ActiveSupport::Notifications.publish(identifier, event) end
subscribe(identifier, callable, async: false)
click to toggle source
# File lib/downstream/pubsub_adapters/stateless/pubsub.rb, line 9 def subscribe(identifier, callable, async: false) Subscriber.new(callable, async: async).tap { |s| s.subscribe(identifier) } end
subscribed(identifier, callable, &block)
click to toggle source
# File lib/downstream/pubsub_adapters/stateless/pubsub.rb, line 13 def subscribed(identifier, callable, &block) ActiveSupport::Notifications.subscribed( Subscriber.new(callable), identifier, &block ) end