class Celluloid::Notifications::Subscriber
Attributes
actor[RW]
method[RW]
pattern[RW]
Public Class Methods
new(actor, pattern, method)
click to toggle source
# File lib/celluloid/notifications.rb, line 68 def initialize(actor, pattern, method) @actor = actor @pattern = pattern @method = method end
Public Instance Methods
matches?(subscriber_or_pattern)
click to toggle source
# File lib/celluloid/notifications.rb, line 85 def matches?(subscriber_or_pattern) self === subscriber_or_pattern || @pattern && @pattern === subscriber_or_pattern end
publish(pattern, *args)
click to toggle source
# File lib/celluloid/notifications.rb, line 74 def publish(pattern, *args) actor.async method, pattern, *args rescue DeadActorError # TODO: needs a tests # Bad shutdown logic. Oh well.... end
subscribed_to?(pattern)
click to toggle source
# File lib/celluloid/notifications.rb, line 81 def subscribed_to?(pattern) !pattern || @pattern === pattern.to_s || @pattern === pattern end