Function mz_compute::communication::initialize_networking_inner

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,