Function run_outside_async_runtime

atomic-cli/src/commands/agent/owner.rs:853–861

(operation: F)

}

fn run_outside_async_runtime<T, F>(operation: F) -> anyhow::Result<T>
where
    T: Send + 'static,
    F: FnOnce() -> anyhow::Result<T> + Send + 'static,
{
    std::thread::spawn(operation)
        .join()
        .map_err(|_| anyhow!("database owner client thread panicked"))?
}

/// Send one request to an already-running owner.
fn request(repository: &Path, request_body: OwnerRequest) -> anyhow::Result<OwnerResponse> {