Function hydro_test::cluster::compute_pi::compute_pi

source ยท 
pub fn compute_pi<'a>(
    flow: &FlowBuilder<'a>,
    batch_size: usize,
) -> (Cluster<'a, Worker>, Process<'a, Leader>)