test(runtime-async): add rust test components for moonbit future/stream cases

Author: peter-jerry-ye

tests/runtime-async/async/moonbit-future-write/test.rs

@@ -0,0 +1,45 @@
+use wit_bindgen::FutureReader;
+
+include!(env!("BINDINGS"));
+
+struct Component;
+
+export!(Component);
+
+impl crate::exports::my::test::i::Guest for Component {
+    async fn create_future_with_value(value: u32) -> FutureReader<u32> {
+        let (tx, rx) = wit_future::new(|| unreachable!());
+        wit_bindgen::spawn(async move {
+            tx.write(value).await.unwrap();
+        });
+        rx
+    }
+
+    async fn create_unit_future() -> FutureReader<()> {
+        let (tx, rx) = wit_future::new(|| unreachable!());
+        wit_bindgen::spawn(async move {
+            tx.write(()).await.unwrap();
+        });
+        rx
+    }
+
+    async fn create_nested_future(value: u32) -> FutureReader<FutureReader<u32>> {
+        let (inner_tx, inner_rx) = wit_future::new(|| unreachable!());
+        let (outer_tx, outer_rx) = wit_future::new(|| unreachable!());
+        wit_bindgen::spawn(async move {
+            outer_tx.write(inner_rx).await.unwrap();
+            inner_tx.write(value).await.unwrap();
+        });
+        outer_rx
+    }
+
+    async fn create_nested_future_record(value: u32) -> crate::exports::my::test::i::NestedFutureRecord {
+        let (inner_tx, inner_rx) = wit_future::new(|| unreachable!());
+        let (outer_tx, outer_rx) = wit_future::new(|| unreachable!());
+        wit_bindgen::spawn(async move {
+            outer_tx.write(inner_rx).await.unwrap();
+            inner_tx.write(value).await.unwrap();
+        });
+        crate::exports::my::test::i::NestedFutureRecord { nested: outer_rx }
+    }
+}

tests/runtime-async/async/moonbit-stream-write/test.rs

@@ -0,0 +1,35 @@
+use wit_bindgen::{StreamReader, StreamResult};
+
+include!(env!("BINDINGS"));
+
+struct Component;
+
+export!(Component);
+
+impl crate::exports::my::test::i::Guest for Component {
+    async fn create_stream_with_values(count: u32) -> StreamReader<u32> {
+        let (mut tx, rx) = wit_stream::new();
+        wit_bindgen::spawn(async move {
+            for i in 0..count {
+                let (result, _rest) = tx.write(vec![i]).await;
+                if !matches!(result, StreamResult::Complete(1)) {
+                    break;
+                }
+            }
+        });
+        rx
+    }
+
+    async fn create_unit_stream(count: u32) -> StreamReader<()> {
+        let (mut tx, rx) = wit_stream::new();
+        wit_bindgen::spawn(async move {
+            for _ in 0..count {
+                let (result, _rest) = tx.write(vec![()]).await;
+                if !matches!(result, StreamResult::Complete(1)) {
+                    break;
+                }
+            }
+        });
+        rx
+    }
+}