follow change of observer.rb. fixed [ruby-core:6796]

git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@9629 b2dd03c8-39d4-4d8f-98ff-823fe69b080e

1 files changed, 11 insertions, 10 deletions

diff --git a/lib/drb/observer.rb b/lib/drb/observer.rb
index e7f1668c52..f2c3455e57 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