diff options
| author | seki <seki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2005-11-29 13:50:27 +0000 |
|---|---|---|
| committer | seki <seki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2005-11-29 13:50:27 +0000 |
| commit | 10d6021a991d04b0652c64946d7c7a6386da0bde (patch) | |
| tree | fa778de9c349eccad943a7943ff57b109507bfc3 /lib/drb/observer.rb | |
| parent | 2387667a1ca29cfccfa33b1cebe1d6b39cd36da3 (diff) | |
| download | ruby-10d6021a991d04b0652c64946d7c7a6386da0bde.tar.gz ruby-10d6021a991d04b0652c64946d7c7a6386da0bde.tar.xz ruby-10d6021a991d04b0652c64946d7c7a6386da0bde.zip | |
follow change of observer.rb. fixed [ruby-core:6796]
git-svn-id: http://svn.ruby-lang.org/repos/ruby/trunk@9629 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'lib/drb/observer.rb')
| -rw-r--r-- | lib/drb/observer.rb | 21 |
1 files changed, 11 insertions, 10 deletions
diff --git a/lib/drb/observer.rb b/lib/drb/observer.rb index e7f1668c5..f2c3455e5 100644 --- a/lib/drb/observer.rb +++ b/lib/drb/observer.rb @@ -6,16 +6,17 @@ module DRb def notify_observers(*arg) if defined? @observer_state and @observer_state - if defined? @observer_peers - for i in @observer_peers.dup - begin - i.update(*arg) - rescue - delete_observer(i) - end - end - end - @observer_state = false + 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 end end end |