Class: Lieutenant::EventBus

Inherits:

Object

• Object
• Lieutenant::EventBus

Defined in:

lib/lieutenant/event_bus.rb

Overview

Publishes and receives messages from the aggregates updates

Instance Method Summary

• #initialize ⇒ EventBus constructor

  A new instance of EventBus.

• #publish(event) ⇒ Object
• #subscribe(*event_classes, &handler) ⇒ Object

Constructor Details

#initialize ⇒ EventBus

Returns a new instance of EventBus.

# File 'lib/lieutenant/event_bus.rb', line 6

def initialize
  @handlers = Hash.new { [] }
end

Instance Method Details

#publish(event) ⇒ Object

# File 'lib/lieutenant/event_bus.rb', line 16

def publish(event)
  handlers[event.class].each { |handler| handler.call(event) }
end

#subscribe(*event_classes, &handler) ⇒ Object

# File 'lib/lieutenant/event_bus.rb', line 10

def subscribe(*event_classes, &handler)
  event_classes.each do |event_class|
    handlers[event_class] = handlers[event_class].push(handler)
  end
end