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