summaryrefslogtreecommitdiffstats
path: root/lib/drb
diff options
context:
space:
mode:
authoryugui <yugui@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2009-03-04 09:20:56 +0000
committeryugui <yugui@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2009-03-04 09:20:56 +0000
commit66f711fc844ccce3d34c5f95928d086ec0915d97 (patch)
treed6d8afc8e8a1f9e3f98226f9f12328e3a93f4be0 /lib/drb
parent03becbf5a5db5945548327230b421bde1bf24fe7 (diff)
merges r22699 from trunk into ruby_1_9_1.
-- merged a patch from Alessandro Di Maria in [ruby-core:22560]. git-svn-id: http://svn.ruby-lang.org/repos/ruby/branches/ruby_1_9_1@22758 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'lib/drb')
-rw-r--r--lib/drb/observer.rb20
1 files changed, 10 insertions, 10 deletions
diff --git a/lib/drb/observer.rb b/lib/drb/observer.rb
index e7f1668c5..149426db7 100644
--- a/lib/drb/observer.rb
+++ b/lib/drb/observer.rb
@@ -6,16 +6,16 @@ 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.each do |observer, method|
+ begin
+ observer.send(method, *arg)
+ rescue
+ delete_observer(observer)
+ end
+ end
+ end
+ @observer_state = false
end
end
end