mz_cluster::communication

Function 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,