Class: Koine::EventManager::EventListener

Inherits:
Object
  • Object
show all
Defined in:
lib/koine/event_manager/event_listener.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ EventListener

Returns a new instance of EventListener.



6
7
8
9
 
# File 'lib/koine/event_manager/event_listener.rb', line 6

def initialize
  @listeners = {}
  @subscribers = {}
end

Instance Method Details

#listen_to(event_type, &block) ⇒ Object

Raises:

  • (ArgumentError) 


11
12
13
14
 
# File 'lib/koine/event_manager/event_listener.rb', line 11

def listen_to(event_type, &block)
  raise ArgumentError, 'block not given' unless block_given?
  add_listener(event_type, &block)
end

#listeners_for(event_type) ⇒ Object 



44
45
46
47
48
 
# File 'lib/koine/event_manager/event_listener.rb', line 44

def listeners_for(event_type)
  listeners.select do |class_or_object, _collection|
    event_type.ancestors.map(&:to_s).include?(class_or_object.to_s)
  end.values.flatten
end

#subscribe(subscriber, to:) ⇒ Object 



16
17
18
19
20
 
# File 'lib/koine/event_manager/event_listener.rb', line 16

def subscribe(subscriber, to:)
  @subscribers[subscriber] ||= []
  @subscribers[subscriber] << to
  @subscribers[subscriber] = @subscribers[subscriber].flatten.map(&:to_s).uniq
end

#trigger(event_object) ⇒ Object 



30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/koine/event_manager/event_listener.rb', line 30

def trigger(event_object)
  listeners_for(event_object.class).each do |block|
    block.call(event_object)
  end

  subscribers.each do |subscriber, events|
    events.each do |event|
      if event_object.class.ancestors.map(&:to_s).include?(event.to_s)
        subscriber.publish(event_object)
      end
    end
  end
end

#unsubscribe(subscriber, from:) ⇒ Object 



22
23
24
25
26
27
28
 
# File 'lib/koine/event_manager/event_listener.rb', line 22

def unsubscribe(subscriber, from:)
  all = Array(subscribers[subscriber])
  filtered = all.reject do |object_type|
    object_type.to_s == from.to_s
  end
  subscribers[subscriber] = filtered
end