pub fn connect_ipc_server() -> anyhow::Result<Channel> {
    let ipc_output = std::env::var(IPC_SERVER_ENV_VAR)?;
    println!("Connecting to server: {}", ipc_output);
    let tx = IpcSender::connect(ipc_output.clone())?;
    let (ch1, ch2) = Channel::duplex()?;
    println!("Connected, sending Channel to server: {}", ipc_output);
    tx.send(ch1)?;
    Ok(ch2)
}
/// This is helper function for implementing child processes
/// Child process will automatically connect to the IPC server
/// passed in the env var "IPC_SERVER".
/// This env var is injected by orchestrator.
/// Execution blocks until connected
///
/// TODO: move to separate client library or set features to exclude all the other unnecessary code
This is helper function for implementing child processes
Child process will automatically connect to the IPC server
passed in the env var "IPC_SERVER".
This env var is injected by orchestrator.
Execution blocks until connected

move to separate client library or set features to exclude all the other unnecessary code
This is helper function for implementing child processes Child process will automatically connect to the IPC server passed in the env var " IPC_SERVER " . This env var is injected by orchestrator . Execution blocks until connected move to separate client library or set features to exclude all the other unnecessary code
pub fn connect_ipc_server() -> anyhow::Result<Channel> {
    let ipc_output = std::env::var(IPC_SERVER_ENV_VAR)?;
    println!("Connecting to server: {}", ipc_output);
    let tx = IpcSender::connect(ipc_output.clone())?;
    let (ch1, ch2) = Channel::duplex()?;
    println!("Connected, sending Channel to server: {}", ipc_output);
    tx.send(ch1)?;
    Ok(ch2)
}
pub fn connect_ipc_server ( ) -> anyhow :: Result < Channel > { let ipc_output = std :: env :: var ( IPC_SERVER_ENV_VAR ) ? ; println ! ( " " ipc_output ) ; let tx = IpcSender :: connect ( ipc_output . clone ( ) ) ? ; let ( ch1 , ch2 ) = Channel :: duplex ( ) ? ; println ! ( " " ipc_output ) ; tx . send ( ch1 ) ? ; Ok ( ch2 ) }
This is helper function for implementing child processes
Child process will automatically connect to the IPC server
passed in the env var "IPC_SERVER".
This is helper function for implementing child processes Child process will automatically connect to the IPC server passed in the env var " IPC_SERVER " .