class Asynchronic::Notifier::Broadcaster

Attributes

broadcaster[R]

Public Class Methods

new(options={}) click to toggle source
# File lib/asynchronic/notifier/broadcaster.rb, line 5
def initialize(options={})
  options[:logger] ||= Asynchronic.logger
  @broadcaster = ::Broadcaster.new options
end

Public Instance Methods

publish(pid, event, data=nil) click to toggle source
# File lib/asynchronic/notifier/broadcaster.rb, line 10
def publish(pid, event, data=nil)
  broadcaster.publish DataStore::Key[pid][event], data
end
subscribe(pid, event, &block) click to toggle source
# File lib/asynchronic/notifier/broadcaster.rb, line 14
def subscribe(pid, event, &block)
  broadcaster.subscribe DataStore::Key[pid][event] do |data|
    block.call data
  end
end
unsubscribe(subscription_id) click to toggle source
# File lib/asynchronic/notifier/broadcaster.rb, line 20
def unsubscribe(subscription_id)
  broadcaster.unsubscribe subscription_id
end
unsubscribe_all() click to toggle source
# File lib/asynchronic/notifier/broadcaster.rb, line 24
def unsubscribe_all
  broadcaster.unsubscribe_all
end