Method: Roby::Distributed.each_updated_peer

Defined in:
lib/roby/distributed/subscription.rb

.each_updated_peer(*objects) ⇒ Object

Yields the peers which are interested in at least one of the objects in objects.



7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
 
# File 'lib/roby/distributed/subscription.rb', line 7

def each_updated_peer(*objects)
		for obj in objects
 return if !obj.distribute?
		end

		for _, peer in Distributed.peers
 next unless peer.connected?
 for obj in objects
			if obj.update_on?(peer)
  yield(peer)
  break
			end
 end
		end
end