fn make_authority_mass_clients()

in fastpay/src/client.rs [44:65]

• 22 lines of code
• 2 McCabe index (conditional complexity)

fn make_authority_mass_clients(
    committee_config: &CommitteeConfig,
    buffer_size: usize,
    send_timeout: std::time::Duration,
    recv_timeout: std::time::Duration,
    max_in_flight: u64,
) -> Vec<(u32, network::MassClient)> {
    let mut authority_clients = Vec::new();
    for config in &committee_config.authorities {
        let client = network::MassClient::new(
            config.network_protocol,
            config.host.clone(),
            config.base_port,
            buffer_size,
            send_timeout,
            recv_timeout,
            max_in_flight / config.num_shards as u64, // Distribute window to diff shards
        );
        authority_clients.push((config.num_shards, client));
    }
    authority_clients
}