rama 0.3.0

modular service framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

use super::utils;

#[tokio::test]
#[ignore]
async fn test_xpc_echo() {
    utils::init_tracing();

    // The example is self-contained: it creates an anonymous XPC channel, exchanges
    // messages between two in-process tokio tasks, then exits. We just verify it exits
    // successfully without panicking.
    let output = escargot::CargoBuild::new()
        .arg("--features=net-apple-xpc")
        .example("xpc_echo")
        .manifest_path("Cargo.toml")
        .target_dir("./target/")
        .run()
        .expect("cargo build xpc_echo")
        .command()
        .env(
            "RUST_LOG",
            std::env::var("RUST_LOG").unwrap_or_else(|_| "debug".into()),
        )
        .env("NO_COLOR", "1")
        .output()
        .expect("run xpc_echo");

    let stdout = String::from_utf8_lossy(&output.stdout);
    let stderr = String::from_utf8_lossy(&output.stderr);
    let combined = format!("{stdout}\n{stderr}");

    assert!(
        output.status.success(),
        "xpc_echo exited with status {}\nstdout:\n{stdout}\nstderr:\n{stderr}",
        output.status,
    );

    assert!(
        combined.contains("xpc_echo::client: got reply"),
        "expected reply line in output:\n{combined}"
    );
}