pub(super) async fn ipc_server() {
    let socket_path = Path::new(SOCKET_PATH);

    init_socket_file(socket_path).await;

    let listener = UnixListener::bind(socket_path).expect("TODO");

    let server_handle = tokio::spawn(async {
        let route = app();

        Server::builder(IpcStreamListener { listener })
            .serve(route.into_make_service_with_connect_info::<IpcConnectionInfo>())
            .await
            .unwrap();
    });

    server_handle.await.unwrap();
}
/// Starts the IPC server and listens for incoming connections
Starts the IPC server and listens for incoming connections
Starts the IPC server and listens for incoming connections
pub(super) async fn ipc_server() {
    let socket_path = Path::new(SOCKET_PATH);
    init_socket_file(socket_path).await;
    let listener = UnixListener::bind(socket_path).expect("TODO");
    let server_handle = tokio::spawn(async {
        let route = app();
        Server::builder(IpcStreamListener { listener })
            .serve(route.into_make_service_with_connect_info::<IpcConnectionInfo>())
            .await
            .unwrap();
    });
    server_handle.await.unwrap();
}
pub ( super ) async fn ipc_server ( ) { let socket_path = Path :: new ( SOCKET_PATH ) ; init_socket_file ( socket_path ) . await ; let listener = UnixListener :: bind ( socket_path ) . expect ( " " ) ; let server_handle = tokio :: spawn ( async { let route = app ( ) ; Server :: builder ( IpcStreamListener { listener } ) . serve ( route . into_make_service_with_connect_info :: < IpcConnectionInfo > ( ) ) . await . unwrap ( ) ; } ) ; server_handle . await . unwrap ( ) ; }
Starts the IPC server and listens for incoming connections
Starts the IPC server and listens for incoming connections