class Celluloid::Notifications::Fanout

Public Class Methods

new() click to toggle source
# File lib/celluloid/notifications.rb, line 28
def initialize
  @subscribers = []
  @listeners_for = {}
end

Public Instance Methods

listeners_for(pattern) click to toggle source
# File lib/celluloid/notifications.rb, line 51
def listeners_for(pattern)
  @listeners_for[pattern] ||= @subscribers.select { |s| s.subscribed_to?(pattern) }
end
listening?(pattern) click to toggle source
# File lib/celluloid/notifications.rb, line 55
def listening?(pattern)
  listeners_for(pattern).any?
end
prune(actor, _reason=nil) click to toggle source
# File lib/celluloid/notifications.rb, line 59
def prune(actor, _reason=nil)
  @subscribers.reject! { |s| s.actor == actor }
  @listeners_for.clear
end
publish(pattern, *args) click to toggle source
# File lib/celluloid/notifications.rb, line 47
def publish(pattern, *args)
  listeners_for(pattern).each { |s| s.publish(pattern, *args) }
end
subscribe(actor, pattern, method) click to toggle source
# File lib/celluloid/notifications.rb, line 33
def subscribe(actor, pattern, method)
  subscriber = Subscriber.new(actor, pattern, method).tap do |s|
    @subscribers << s
  end
  link actor
  @listeners_for.clear
  subscriber
end
unsubscribe(subscriber) click to toggle source
# File lib/celluloid/notifications.rb, line 42
def unsubscribe(subscriber)
  @subscribers.reject! { |s| s.matches?(subscriber) }
  @listeners_for.clear
end