test(jco): add test for stream of list<record>

Author: vados-cosmonic

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

@@ -123,6 +123,12 @@ impl use_stream_async::Guest for Component {
     ) -> Vec<Vec<[u32; 5]>> {
         read_async_values(rx).await
     }
+
+    async fn read_stream_values_list_record(
+        rx: StreamReader<Vec<ExampleRecord>>,
+    ) -> Vec<Vec<ExampleRecord>> {
+        read_async_values(rx).await
+    }
 }
 
 async fn read_async_values<T>(mut rx: StreamReader<T>) -> Vec<T> {

crates/test-components/wit/all.wit

@@ -229,7 +229,7 @@ interface use-stream-async {
     read-stream-values-list-u8: async func(s: stream<list<u8>>) -> list<list<u8>>;
     read-stream-values-list-string: async func(s: stream<list<string>>) -> list<list<string>>;
     read-stream-values-fixed-list-u32: async func(s: stream<list<list<u32, 5>>>) -> list<list<list<u32, 5>>>;
-    // read-stream-values-list-record: async func(s: stream<list<example-record>>) -> list<list<example-record>>;
+    read-stream-values-list-record: async func(s: stream<list<example-record>>) -> list<list<example-record>>;
 
     // // NOTE: the check here will be whether the resources are disposed inside the component properly
     // read-stream-values-example-resource-own: async func(s: stream<example-resource>);

packages/jco/test/p3/stream-lowers.js

@@ -372,4 +372,22 @@ suite("stream<T> lowers", () => {
             ],
         ]);
     });
+
+    test.concurrent("list<example-record>", async () => {
+        assert.instanceOf(instance["jco:test-components/use-stream-async"].readStreamValuesListRecord, AsyncFunction);
+
+        let vals = [
+            [ { id: 3, idStr: "three" },
+              { id: 2, idStr: "two" },
+              { id: 1, idStr: "one" }, ],
+            [ { id: 1, idStr: "one-one" },
+              { id: 2, idStr: "two-two" },
+              { id: 3, idStr: "three-three" }, ],
+        ];
+        let returnedVals = await instance["jco:test-components/use-stream-async"].readStreamValuesListRecord(
+            createReadableStreamFromValues(vals),
+        );
+        assert.deepEqual(returnedVals, vals);
+    });
+
 });