diff --git a/protocol/p2p/src/core/hub.rs b/protocol/p2p/src/core/hub.rs index 0bd9fe070..dad8ddd9d 100644 --- a/protocol/p2p/src/core/hub.rs +++ b/protocol/p2p/src/core/hub.rs @@ -110,7 +110,8 @@ impl Hub { let peers = self.peers.read().values().cloned().collect::>(); // TODO: At least some of the peers should be outbound, because an attacker can gain less control // over the set of outbound peers. - for router in peers.choose_multiple(&mut rand::thread_rng(), num_peers) { + let peers = peers.choose_multiple(&mut rand::thread_rng(), num_peers).cloned().collect::>(); + for router in peers { let _ = router.enqueue(msg.clone()).await; } }