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