Class: OPQ::Observer

Inherits:

Object

show all

Instance Method Summary collapse

Returns a new instance of Observer.



4
5
6

# File 'lib/opqr/observer.rb', line 4

def initialize(observers)
  @observers = observers
end



8
9
10

# File 'lib/opqr/observer.rb', line 8

def add_observer(observer)
  @observers << observer
end



16
17
18

# File 'lib/opqr/observer.rb', line 16

def notify_observers(data)
  @observers.each { |observer| observer.on_data_received(data) }
end



20
21
22

# File 'lib/opqr/observer.rb', line 20

def on_message_received(msg)
  notify_observers(msg)
end



12
13
14

# File 'lib/opqr/observer.rb', line 12

def remove_observer(observer)
  @observers.delete(observer)
end