# File lib/celluloid/notifications.rb, line 3defself.notifierActor[:notifications_fanout] orraiseDeadActorError, "notifications fanout actor not running"end
Public Instance Methods
publish(pattern, *args)click to toggle source
# File lib/celluloid/notifications.rb, line 7defpublish(pattern, *args)
Celluloid::Notifications.notifier.publish(pattern, *args)
end
subscribe(pattern, method)click to toggle source
# File lib/celluloid/notifications.rb, line 11defsubscribe(pattern, method)
Celluloid::Notifications.notifier.subscribe(Actor.current, pattern, method)
end
unsubscribe(*args)click to toggle source
# File lib/celluloid/notifications.rb, line 15defunsubscribe(*args)
Celluloid::Notifications.notifier.unsubscribe(*args)
end