feagi-structures 0.0.10

The most core library, defines the basic data types used by FEAGI, as well as some processors to modify them
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

/// Run an async function with the platform-appropriate runtime.
///
/// Creates or gets a handle to the runtime based on the enabled feature,
/// calls the provided async function, and awaits the result.
///
/// Use this inside any async context (`#[tokio::test]`, `#[tokio::main]`,
/// `#[wasm_bindgen_test]`, etc.).
///
/// # Usage
///
/// ```ignore
/// use feagi_structures::async::FeagiAsyncRuntime;
///
/// async fn my_async_work<R: FeagiAsyncRuntime>(runtime: &R) -> i32 {
///     let handle = runtime.spawn(async { 42 });
///     handle.await
/// }
///
/// #[tokio::test]  // or #[wasm_bindgen_test] on WASM
/// async fn test_something() {
///     let result = feagi_structures::run_async!(my_async_work);
///     assert_eq!(result, 42);
/// }
/// ```
#[cfg(feature = "async")]
#[macro_export]
macro_rules! run_async {
    ($func:expr) => {{
        // Check for conflicting feature combinations
        #[cfg(all(feature = "async-tokio", feature = "async-wasm"))]
        compile_error!("Do not enable both async-tokio and async-wasm features!");

        #[cfg(all(feature = "async-tokio", feature = "async-wasi"))]
        compile_error!("Do not enable both async-tokio and async-wasi features!");

        #[cfg(all(feature = "async-wasm", feature = "async-wasi"))]
        compile_error!("Do not enable both async-wasm and async-wasi features!");

        #[cfg(not(any(
            feature = "async-tokio",
            feature = "async-wasm",
            feature = "async-wasi"
        )))]
        compile_error!(
            "No async runtime feature enabled! Enable one of: async-tokio, async-wasm, async-wasi"
        );

        // Get/create the appropriate runtime and run the function
        #[cfg(feature = "async-tokio")]
        {
            let runtime = $crate::r#async::TokioHandle::current();
            $func(&runtime).await
        }

        #[cfg(feature = "async-wasm")]
        {
            let runtime = $crate::r#async::WasmRuntime::new();
            $func(&runtime).await
        }

        #[cfg(feature = "async-wasi")]
        {
            let runtime = $crate::r#async::WasiHandle::current();
            $func(&runtime).await
        }
    }};
}