pub fn initialize_networking_from_sockets<S>(
    sockets: Vec<Option<S>>,
    my_index: usize,
    threads: usize,
    log_sender: Box<dyn Fn(CommunicationSetup) -> Option<Logger<CommunicationEvent, CommunicationSetup>> + Sync + Send>
) -> Result<(Vec<TcpBuilder<ProcessBuilder>>, CommsGuard), Error>
where S: Stream + 'static,
Expand description

Initialize send and recv threads from sockets.

This method is available for users who have already connected sockets and simply wish to construct a vector of process-local allocators connected to instantiated send and recv threads.

It is important that the sockets argument contain sockets for each remote process, in order, and with position my_index set to None.