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