mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
32d051b692
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/branches/ruby_1_8@6303 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
22 lines
369 B
Ruby
22 lines
369 B
Ruby
require 'observer'
|
|
|
|
module DRb
|
|
module DRbObservable
|
|
include Observable
|
|
|
|
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
|
|
end
|
|
end
|
|
end
|
|
end
|