pub fn listeners_are_ready<I>(ids: I) -> impl FnMut(ClusterEvent) -> Ready<bool>where
I: IntoIterator<Item = RustNodeId>,
Expand description
Predicate returning true for a cluster event corresponging to the specified node started listening.
pub fn listeners_are_ready<I>(ids: I) -> impl FnMut(ClusterEvent) -> Ready<bool>where
I: IntoIterator<Item = RustNodeId>,
Predicate returning true for a cluster event corresponging to the specified node started listening.