Skip to main content

wait_for_committee

Function wait_for_committee 

Source
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.