graphix-stdlib 0.3.1

A dataflow language for UIs and network programming, standard library
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84

use crate::{run_with_tempdir, test::init};
use anyhow::Result;
use arcstr::ArcStr;
use graphix_rt::GXEvent;
use netidx::subscriber::Value;
use poolshark::global::GPooled;
use tokio::fs;
use tokio::sync::mpsc;
use tokio::time::Duration;

run_with_tempdir! {
    name: test_read_all_basic,
    code: r#"fs::read_all("{}")"#,
    setup: |temp_dir| {
        let test_file = temp_dir.path().join("test.txt");
        let content = "Hello, World!";
        fs::write(&test_file, content).await?;
        test_file
    },
    expect: |v: Value| -> Result<()> {
        if let Value::String(s) = v {
            assert_eq!(&*s, "Hello, World!");
            Ok(())
        } else {
            panic!("expected String value, got: {v:?}")
        }
    }
}

run_with_tempdir! {
    name: test_read_all_nonexistent,
    code: r#"fs::read_all("{}")"#,
    setup: |temp_dir| {
        temp_dir.path().join("nonexistent.txt")
    },
    expect_error
}

run_with_tempdir! {
    name: test_read_all_utf8,
    code: r#"fs::read_all("{}")"#,
    setup: |temp_dir| {
        let test_file = temp_dir.path().join("utf8.txt");
        let content = "Hello, δΈ–η•Œ! πŸ¦€";
        fs::write(&test_file, content).await?;
        test_file
    },
    expect: |v: Value| -> Result<()> {
        if let Value::String(s) = v {
            assert_eq!(&*s, "Hello, δΈ–η•Œ! πŸ¦€");
            Ok(())
        } else {
            panic!("expected String value, got: {v:?}")
        }
    }
}

run_with_tempdir! {
    name: test_read_all_bin_basic,
    code: r#"fs::read_all_bin("{}")"#,
    setup: |temp_dir| {
        let test_file = temp_dir.path().join("test.bin");
        let content = b"Binary data \x00\x01\x02\xff";
        fs::write(&test_file, content).await?;
        test_file
    },
    expect: |v: Value| -> Result<()> {
        if let Value::Bytes(b) = v {
            assert_eq!(b.as_ref(), b"Binary data \x00\x01\x02\xff");
            Ok(())
        } else {
            panic!("expected Bytes value, got: {v:?}")
        }
    }
}

run_with_tempdir! {
    name: test_read_all_bin_nonexistent,
    code: r#"fs::read_all_bin("{}")"#,
    setup: |temp_dir| {
        temp_dir.path().join("nonexistent.bin")
    },
    expect_error
}