Class: RubyEventStore::PubSub::Broker
- Inherits:
-
Object
- Object
- RubyEventStore::PubSub::Broker
- Defined in:
- lib/ruby_event_store/pub_sub/broker.rb
Constant Summary collapse
- DEFAULT_DISPATCHER =
Dispatcher.new
Instance Method Summary collapse
- #add_global_subscriber(subscriber) ⇒ Object
- #add_subscriber(subscriber, event_types) ⇒ Object
-
#initialize(dispatcher: DEFAULT_DISPATCHER) ⇒ Broker
constructor
A new instance of Broker.
- #notify_subscribers(event) ⇒ Object
Constructor Details
#initialize(dispatcher: DEFAULT_DISPATCHER) ⇒ Broker
Returns a new instance of Broker.
6 7 8 9 10 |
# File 'lib/ruby_event_store/pub_sub/broker.rb', line 6 def initialize(dispatcher: DEFAULT_DISPATCHER) @subscribers = Hash.new {|hsh, key| hsh[key] = [] } @global_subscribers = [] @dispatcher = dispatcher end |
Instance Method Details
#add_global_subscriber(subscriber) ⇒ Object
17 18 19 20 21 22 |
# File 'lib/ruby_event_store/pub_sub/broker.rb', line 17 def add_global_subscriber(subscriber) verify_subscriber(subscriber) @global_subscribers << subscriber ->() { @global_subscribers.delete(subscriber) } end |
#add_subscriber(subscriber, event_types) ⇒ Object
12 13 14 15 |
# File 'lib/ruby_event_store/pub_sub/broker.rb', line 12 def add_subscriber(subscriber, event_types) verify_subscriber(subscriber) subscribe(subscriber, event_types) end |
#notify_subscribers(event) ⇒ Object
24 25 26 27 28 |
# File 'lib/ruby_event_store/pub_sub/broker.rb', line 24 def notify_subscribers(event) all_subscribers_for(event.class).each do |subscriber| @dispatcher.call(subscriber, event) end end |