Function register_validators

node/src/test_harness/common.rs:97–131

(
    oracle: &Oracle<PublicKey, E>,
    validators: &[PublicKey],
)

            .add_link(existing.clone(), validator.clone(), link.clone())
            .await
            .unwrap();
    }
}

pub async fn register_validators<E: Clock>(
    oracle: &Oracle<PublicKey, E>,
    validators: &[PublicKey],
) -> HashMap<
    PublicKey,
    (
        (Sender<PublicKey, E>, Receiver<PublicKey>),
        (Sender<PublicKey, E>, Receiver<PublicKey>),
        (Sender<PublicKey, E>, Receiver<PublicKey>),
        (Sender<PublicKey, E>, Receiver<PublicKey>),
        (Sender<PublicKey, E>, Receiver<PublicKey>),
    ),
> {
    let mut registrations = HashMap::new();
    let quota = Quota::per_second(NonZeroU32::MAX);
    for validator in validators.iter() {
        let control = oracle.control(validator.clone());
        let (pending_sender, pending_receiver) = control.register(0, quota).await.unwrap();
        let (recovered_sender, recovered_receiver) = control.register(1, quota).await.unwrap();
        let (resolver_sender, resolver_receiver) = control.register(2, quota).await.unwrap();
        let (broadcast_sender, broadcast_receiver) = control.register(3, quota).await.unwrap();
        let (backfill_sender, backfill_receiver) = control.register(4, quota).await.unwrap();
        registrations.insert(
            validator.clone(),
            (
                (pending_sender, pending_receiver),
                (recovered_sender, recovered_receiver),
                (resolver_sender, resolver_receiver),
                (broadcast_sender, broadcast_receiver),
                (backfill_sender, backfill_receiver),
            ),
        );
    }
    registrations