pub async fn wait_for_committee(
client: &Client<ClientErr, SequencerApiVersion>,
events: &mut (impl Stream<Item = CoordinatorEvent<SeqTypes>> + Unpin),
epoch_height: u64,
start_epoch: u64,
max_epochs: u64,
pred: impl Fn(&AuthenticatedValidatorMap) -> bool,
) -> (u64, AuthenticatedValidatorMap)Expand description
Waits epoch by epoch, starting at start_epoch, until the committee
reported by node/validators/{epoch} satisfies pred. Returns the
first matching epoch and its committee; panics after max_epochs
epochs without a match.