test(jco): enable nested stream test

Author: vados-cosmonic

crates/test-components/src/bin/stream_tx.rs

@@ -204,6 +204,20 @@ impl get_stream_async::Guest for Component {
         });
         Ok(rx)
     }
+
+    async fn get_stream_stream_string(
+        vals: Vec<String>,
+    ) -> Result<StreamReader<StreamReader<String>>, String> {
+        let (mut tx, rx) = wit_stream::new();
+        wit_bindgen::spawn(async move {
+            for v in vals {
+                let (mut nested_tx, nested_rx) = wit_stream::new();
+                tx.write(vec![nested_rx]).await;
+                nested_tx.write(vec![v]).await;
+            }
+        });
+        Ok(rx)
+    }
 }
 
 fn stream_values_async<T: StreamPayload>(vals: Vec<T>) -> Result<StreamReader<T>, String> {

crates/test-components/wit/all.wit

@@ -110,7 +110,8 @@ interface get-stream-async {
 
     get-stream-example-resource-own-attr: async func(vals: list<example-resource>) -> result<stream<u32>, string>;
 
-    //get-stream-stream-string: async func(vals: list<stream<string>>) -> result<stream<stream<string>>, string>;
+    get-stream-stream-string: async func(vals: list<string>) -> result<stream<stream<string>>, string>;
+
     //get-stream-future-string: async func(vals: list<future<string>>) -> result<stream<future<string>>, string>;
 }
 

packages/jco/test/p3/stream.js

@@ -345,6 +345,16 @@ suite("stream<T> lifts", () => {
             expectedValues: [2, 1, 0],
         });
     });
+
+    test("stream<string>", async () => {
+        assert.instanceOf(instance["jco:test-components/get-stream-async"].getStreamStreamString, AsyncFunction);
+        let vals = ["first", "third", "second"];
+        let stream = await instance["jco:test-components/get-stream-async"].getStreamStreamString(vals);
+        for (const v of vals) {
+            const nestedStream = await stream.next();
+            assert.strictEqual(v, await nestedStream.next());
+        }
+    });
 });
 
 async function checkStreamValues(args) {