test(jco): add async stream lower variant test

Author: vados-cosmonic

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

@@ -11,7 +11,7 @@ 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;
+use bindings::exports::jco::test_components::use_stream_async::{ExampleVariant, ExampleRecord};
 
 struct Component;
 
@@ -77,6 +77,10 @@ impl use_stream_async::Guest for Component {
     async fn read_stream_values_record(rx: StreamReader<ExampleRecord>) -> Vec<ExampleRecord> {
         read_async_values(rx).await
     }
+
+    async fn read_stream_values_variant(rx: StreamReader<ExampleVariant>) -> Vec<ExampleVariant> {
+        read_async_values(rx).await
+    }
 }
 
 async fn read_async_values<T>(mut rx: StreamReader<T>) -> Vec<T> {

crates/test-components/wit/all.wit

@@ -28,7 +28,7 @@ interface example-types {
         num(u32),
         str(string),
         float(f32),
-        maybe-bool(option<u32>),
+        maybe-u32(option<u32>),
     }
 
     enum example-enum {
@@ -214,7 +214,7 @@ interface use-stream-async {
 
     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>;
+    read-stream-values-variant: async func(s: stream<example-variant>) -> list<example-variant>;
 
     // 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>>;

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

@@ -192,8 +192,8 @@ suite("stream<T> lifts", () => {
         assert.instanceOf(instance["jco:test-components/get-stream-async"].getStreamVariant, AsyncFunction);
 
         const vals = [
-            { tag: "maybe-bool", val: 123 },
-            { tag: "maybe-bool", val: null },
+            { tag: "maybe-u32", val: 123 },
+            { tag: "maybe-u32", val: null },
             { tag: "float", val: 123.1 },
             { tag: "str", val: "string-value" },
             { tag: "num", val: 1 },
@@ -206,11 +206,11 @@ suite("stream<T> lifts", () => {
             vals: [
                 // TODO: wit type representation smoothing mismatch,
                 // non-nullable option<t> values are *not* wrapped as objects
-                { tag: "maybe-bool", val: { tag: "some", val: 123 } },
-                { tag: "maybe-bool", val: { tag: "none" } },
+                { tag: "maybe-u32", val: { tag: "some", val: 123 } },
+                { tag: "maybe-u32", val: { tag: "none" } },
             ],
             partial: true,
-            typeName: "variant<maybe-bool>",
+            typeName: "variant<maybe-u32>",
             assertEqFn: assert.deepEqual,
         });
 

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

@@ -228,6 +228,22 @@ suite("stream<T> lowers", () => {
         assert.deepEqual(returnedVals, vals);
     });
 
+    test.skip("variant", async () => {
+        assert.instanceOf(instance["jco:test-components/use-stream-async"].readStreamValuesVariant, AsyncFunction);
+
+        let vals = [
+            { tag: "maybe-u32", val: 123 },
+            { tag: "maybe-u32", val: null },
+            { tag: "float", val: 123.1 },
+            { tag: "str", val: "string-value" },
+            { tag: "num", val: 1 },
+        ];
+        let returnedVals = await instance["jco:test-components/use-stream-async"].readStreamValuesVariant(
+            createReadableStreamFromValues(vals),
+        );
+        assert.deepEqual(returnedVals, vals);
+    });
+
 });
 
 function createReadableStreamFromValues(vals) {