Function mz_cluster::communication::initialize_networking_inner

source ยท 
fn initialize_networking_inner<S>(
    sockets: Vec<Option<S>>,
    process: usize,
    workers: usize,
) -> Result<(Vec<GenericBuilder>, Box<dyn Any + Send>), Error>
where
    S: Stream + 'static,