Module: ActorSystem::Core::ObservableImplementation

Included in:
ObservableExample, Prop
Defined in:
lib/actor_system/core/observable_implementation.rb

Instance Method Summary collapse

Instance Method Details

#add_observer(object) ⇒ Object 



16
17
18
19
20
 
# File 'lib/actor_system/core/observable_implementation.rb', line 16

def add_observer(object)
  mutex.synchronize do
    observers << object
  end
end

#notify_observers(*args) ⇒ Object 



8
9
10
11
12
13
14
 
# File 'lib/actor_system/core/observable_implementation.rb', line 8

def notify_observers(*args)
  observers.each do |observer|
    mutex.synchronize do
      observer.observer_update(*args) if observer.respond_to? :observer_update
    end
  end
end

#observers ⇒ Object 



4
5
6
 
# File 'lib/actor_system/core/observable_implementation.rb', line 4

def observers
  @observers || @observers = []
end