test(jco): add async record lower test

Author: vados-cosmonic

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

@@ -11,6 +11,8 @@ use wit_bindgen::StreamReader;
 use bindings::exports::jco::test_components::use_stream_async;
 use bindings::exports::jco::test_components::use_stream_sync;
 
+use bindings::exports::jco::test_components::use_stream_async::ExampleRecord;
+
 struct Component;
 
 impl use_stream_sync::Guest for Component {
@@ -71,6 +73,10 @@ impl use_stream_async::Guest for Component {
     async fn read_stream_values_string(rx: StreamReader<String>) -> Vec<String> {
         read_async_values(rx).await
     }
+
+    async fn read_stream_values_record(rx: StreamReader<ExampleRecord>) -> 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

@@ -212,7 +212,7 @@ interface use-stream-async {
 
     read-stream-values-string: async func(s: stream<string>) -> list<string>;
 
-    // read-stream-values-record: async func(s: stream<example-record>) -> list<example-record>;
+    read-stream-values-record: async func(s: stream<example-record>) -> list<example-record>;
 
     // read-stream-values-variant: async func(s: stream<example-variant>) -> list<example-variant>;
 

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

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