2003-06-18 15:45:12 +00:00
|
|
|
require 'observer'
|
|
|
|
|
|
|
|
module DRb
|
|
|
|
module DRbObservable
|
|
|
|
include Observable
|
|
|
|
|
|
|
|
def notify_observers(*arg)
|
|
|
|
if defined? @observer_state and @observer_state
|
2005-11-29 13:50:27 +00:00
|
|
|
if defined? @observer_peers
|
|
|
|
@observer_peers.delete_if do |k, v|
|
|
|
|
begin
|
|
|
|
k.send(v, *arg)
|
|
|
|
false
|
|
|
|
rescue
|
|
|
|
true
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
@observer_state = false
|
2003-06-18 15:45:12 +00:00
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|