Permalink
Browse files

evented listeners can subscribe to any message

  • Loading branch information...
tenderlove committed Mar 21, 2012
1 parent 6989db9 commit c7847f14fde3263fc06e0bad8448949848163d0d
Showing with 27 additions and 9 deletions.
  1. +27 −9 activesupport/lib/active_support/notifications/fanout.rb
@@ -47,17 +47,19 @@ def wait
module Subscribers # :nodoc:
def self.new(pattern, listener)
if listener.respond_to?(:call)
- if pattern
- TimedSubscriber.new pattern, listener
- else
- AllMessages.new pattern, listener
- end
+ subscriber = Timed.new pattern, listener
else
- Subscriber.new pattern, listener
+ subscriber = Evented.new pattern, listener
+ end
+
+ unless pattern
+ AllMessages.new(subscriber)
+ else
+ subscriber
end
end
- class Subscriber #:nodoc:
+ class Evented #:nodoc:
def initialize(pattern, delegate)
@pattern = pattern
@delegate = delegate
@@ -81,7 +83,7 @@ def matches?(subscriber_or_name)
end
end
- class TimedSubscriber < Subscriber
+ class Timed < Evented
def initialize(pattern, delegate)
@timestack = Hash.new { |h,id|
h[id] = Hash.new { |ids,name| ids[name] = [] }
@@ -103,7 +105,23 @@ def finish(name, id, payload)
end
end
- class AllMessages < TimedSubscriber # :nodoc:
+ class AllMessages # :nodoc:
+ def initialize(delegate)
+ @delegate = delegate
+ end
+
+ def start(name, id, payload)
+ @delegate.start name, id, payload
+ end
+
+ def finish(name, id, payload)
+ @delegate.finish name, id, payload
+ end
+
+ def publish(name, *args)
+ @delegate.publish name, *args
+ end
+
def subscribed_to?(name)
true
end

0 comments on commit c7847f1

Please sign in to comment.