Class: Synapse::EventBus::SimpleEventBus

Inherits:
EventBus
  • Object
show all
Defined in:
lib/synapse/event_bus/simple_event_bus.rb

Overview

Implementation of an event bus that notifies any subscribed event listeners in the calling thread. Listeners are expected to implement asynchronous handing themselves, if desired.

Instance Method Summary collapse

Constructor Details

#initialize ⇒ SimpleEventBus

Returns a new instance of SimpleEventBus.



6
7
8
9
 
# File 'lib/synapse/event_bus/simple_event_bus.rb', line 6

def initialize
  @listeners = Set.new
  @logger = Logging.logger[self.class]
end

Instance Method Details

#publish(*events) ⇒ undefined

Parameters:

  • events (EventMessage...)

Returns:

  • (undefined) 


14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/synapse/event_bus/simple_event_bus.rb', line 14

def publish(*events)
  return if @listeners.empty?

  events.flatten!
  events.each do |event|
    @listeners.each do |listener|
      @logger.debug 'Dispatching event [%s] to listener [%s]' %
        [event.payload_type, listener.class]

      listener.notify event
    end
  end
end

#subscribe(listener) ⇒ undefined

Parameters:

Returns:

  • (undefined) 


40
41
42
43
44
45
46
 
# File 'lib/synapse/event_bus/simple_event_bus.rb', line 40

def subscribe(listener)
  if @listeners.add? listener
    @logger.debug 'Event listener [%s] subscribed' % listener.class
  else
    @logger.info 'Event listener [%s] not added, was already subscribed' % listener.class
  end
end

#subscribed?(listener) ⇒ Boolean

Returns true if the given listener is subscribed to this event bus

Parameters:

Returns:

  • (Boolean) 


33
34
35
 
# File 'lib/synapse/event_bus/simple_event_bus.rb', line 33

def subscribed?(listener)
  @listeners.include? listener
end

#unsubscribe(listener) ⇒ undefined

Parameters:

Returns:

  • (undefined) 


51
52
53
54
55
56
57
 
# File 'lib/synapse/event_bus/simple_event_bus.rb', line 51

def unsubscribe(listener)
  if @listeners.delete? listener
    @logger.debug 'Event listener [%s] unsubscribed' % listener.class
  else
    @logger.info 'Event listener [%s] not removed, was not subscribed' % listener.class
  end
end