Function try_wait_for_all_node_peer

pub async fn try_wait_for_all_node_peer<I, F>(
    cluster: &mut Cluster,
    nodes_peers: I,
    time: Duration,
    f: F,
) -> Result<bool, ClusterEvent>
where
    I: IntoIterator<Item = (RustNodeId, PeerId)>,
    F: FnMut(RustNodeEvent) -> Option<PeerId>,

Tries to wait for particular event to happen for all specified pairs of (node, peer_id).

Function f extract peer_id from a Rust event.

See super::predicates::all_nodes_with_value.