| Module | DRb::DRbObservable |
| In: |
lib/drb/observer.rb
|
# File lib/drb/observer.rb, line 7
7: def notify_observers(*arg)
8: if defined? @observer_state and @observer_state
9: if defined? @observer_peers
10: for i in @observer_peers.dup
11: begin
12: i.update(*arg)
13: rescue
14: delete_observer(i)
15: end
16: end
17: end
18: @observer_state = false
19: end
20: end