Function hydro_test::cluster::bench_client::bench_client

source ยท 
pub fn bench_client<'a>(
    clients: &Cluster<'a, Client>,
    transaction_cycle: impl FnOnce(Stream<(u32, u32), Cluster<'a, Client>, Unbounded>) -> Stream<(u32, u32), Cluster<'a, Client>, Unbounded, NoOrder>,
    num_clients_per_node: usize,
    median_latency_window_size: usize,
)