| Module | DRb::Observable |
| In: |
lib/drb/observable.rb
|
# File lib/drb/observable.rb, line 35 def notify_observer(observer, *arg, &block) if defined? @observer_state and @observer_state if defined? @observer_peers if @observer_peers.include?(observer) begin observer.update(*arg, &block) rescue delete_observer(observer) end end end @observer_state = false end end