Class: ActiveSupport::Notifications::Fanout
- Defined in:
- lib/active_support/notifications/fanout.rb
Overview
This is a default queue implementation that ships with Notifications. It just pushes events to all registered log subscribers.
Defined Under Namespace
Classes: Subscriber
Instance Method Summary collapse
-
#initialize ⇒ Fanout
constructor
A new instance of Fanout.
- #listeners_for(name) ⇒ Object
- #listening?(name) ⇒ Boolean
- #publish(name, *args) ⇒ Object
- #subscribe(pattern = nil, block = Proc.new) ⇒ Object
- #unsubscribe(subscriber) ⇒ Object
-
#wait ⇒ Object
This is a sync queue, so there is no waiting.
Constructor Details
#initialize ⇒ Fanout
Returns a new instance of Fanout.
6 7 8 9 |
# File 'lib/active_support/notifications/fanout.rb', line 6 def initialize @subscribers = [] @listeners_for = {} end |
Instance Method Details
#listeners_for(name) ⇒ Object
28 29 30 |
# File 'lib/active_support/notifications/fanout.rb', line 28 def listeners_for(name) @listeners_for[name] ||= @subscribers.select { |s| s.subscribed_to?(name) } end |
#listening?(name) ⇒ Boolean
32 33 34 |
# File 'lib/active_support/notifications/fanout.rb', line 32 def listening?(name) listeners_for(name).any? end |
#publish(name, *args) ⇒ Object
24 25 26 |
# File 'lib/active_support/notifications/fanout.rb', line 24 def publish(name, *args) listeners_for(name).each { |s| s.publish(name, *args) } end |
#subscribe(pattern = nil, block = Proc.new) ⇒ Object
11 12 13 14 15 16 17 |
# File 'lib/active_support/notifications/fanout.rb', line 11 def subscribe(pattern = nil, block = Proc.new) subscriber = Subscriber.new(pattern, block).tap do |s| @subscribers << s end @listeners_for.clear subscriber end |
#unsubscribe(subscriber) ⇒ Object
19 20 21 22 |
# File 'lib/active_support/notifications/fanout.rb', line 19 def unsubscribe(subscriber) @subscribers.reject! {|s| s.matches?(subscriber)} @listeners_for.clear end |
#wait ⇒ Object
This is a sync queue, so there is no waiting.
37 38 |
# File 'lib/active_support/notifications/fanout.rb', line 37 def wait end |