pub fn all_nodes_peers_are_ready<I>(
nodes_peers: I,
) -> impl FnMut(ClusterEvent) -> Ready<bool>where
I: IntoIterator<Item = (NodeId, PeerId)>,
Expand description
Returns a predicate over cluster events that returns true
once it is
called at least once for events that represent established connection
between a node and a peer from the nodes_peers
.