pub async fn wait_for_all_nodes_to_connect<I>(
cluster: &mut Cluster,
nodes_peers: I,
time: Duration,
) -> boolwhere
I: IntoIterator<Item = (NodeId, PeerId)>,
Expand description
Runs the cluster for specified period of time
, returning true
early if
for each specified pair of node id and peer id there was a succesfull
connection.