feat: add support for stream with no <T> (#1130)

* feat: add support for `stream` with no `<T>`

Signed-off-by: Roman Volosatovs <[email protected]>

test: return `future` in future return test WIT

Signed-off-by: Roman Volosatovs <[email protected]>

build: update wasm-tools

Signed-off-by: Roman Volosatovs <[email protected]>

avoid divide-by-zero in `StreamReader::poll_next`

I hit this when testing "unit streams" (i.e. streams with no payload type)
end-to-end.

BTW, I can't wait to get some runtime tests going in this repo so we can catch
this kind of thing in CI.

Signed-off-by: Joel Dice <[email protected]>

* update to latest wasm-tools

Signed-off-by: Joel Dice <[email protected]>

---------

Signed-off-by: Joel Dice <[email protected]>
Co-authored-by: Joel Dice <[email protected]>

Author: rvolosatovs

Cargo.lock

@@ -33,11 +33,11 @@ prettyplease = "0.2.20"
 syn = { version = "2.0.89", features = ["printing"] }
 futures = "0.3.31"
 
-wasmparser = "0.223.0"
-wasm-encoder = "0.223.0"
-wasm-metadata = "0.223.0"
-wit-parser = "0.223.0"
-wit-component = "0.223.0"
+wasmparser = "0.224.0"
+wasm-encoder = "0.224.0"
+wasm-metadata = "0.224.0"
+wit-parser = "0.224.0"
+wit-component = "0.224.0"
 
 wit-bindgen-core = { path = 'crates/core', version = '0.37.0' }
 wit-bindgen-c = { path = 'crates/c', version = '0.37.0' }

Cargo.toml

@@ -1352,7 +1352,7 @@ void __wasm_export_{ns}_{snake}_dtor({ns}_{snake}_t* arg) {{
         todo!()
     }
 
-    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Type, docs: &Docs) {
+    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Option<Type>, docs: &Docs) {
         _ = (id, name, ty, docs);
         todo!()
     }
@@ -1450,7 +1450,7 @@ impl<'a> wit_bindgen_core::AnonymousTypeGenerator<'a> for InterfaceGenerator<'a>
         todo!("print_anonymous_type for future");
     }
 
-    fn anonymous_type_stream(&mut self, _id: TypeId, _ty: &Type, _docs: &Docs) {
+    fn anonymous_type_stream(&mut self, _id: TypeId, _ty: &Option<Type>, _docs: &Docs) {
         todo!("print_anonymous_type for stream");
     }
 

crates/c/src/lib.rs

@@ -364,13 +364,13 @@ def_instruction! {
 
         /// Create an `i32` from a stream.
         StreamLower {
-            payload: &'a Type,
+            payload: &'a Option<Type>,
             ty: TypeId,
         } : [1] => [1],
 
         /// Create a stream from an `i32`.
         StreamLift {
-            payload: &'a Type,
+            payload: &'a Option<Type>,
             ty: TypeId,
         } : [1] => [1],
 

crates/core/src/abi.rs

@@ -155,7 +155,7 @@ pub trait InterfaceGenerator<'a> {
     fn type_list(&mut self, id: TypeId, name: &str, ty: &Type, docs: &Docs);
     fn type_builtin(&mut self, id: TypeId, name: &str, ty: &Type, docs: &Docs);
     fn type_future(&mut self, id: TypeId, name: &str, ty: &Option<Type>, docs: &Docs);
-    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Type, docs: &Docs);
+    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Option<Type>, docs: &Docs);
     fn type_error_context(&mut self, id: TypeId, name: &str, docs: &Docs);
     fn types(&mut self, iface: InterfaceId) {
         let iface = &self.resolve().interfaces[iface];
@@ -195,7 +195,7 @@ pub trait AnonymousTypeGenerator<'a> {
     fn anonymous_type_result(&mut self, id: TypeId, ty: &Result_, docs: &Docs);
     fn anonymous_type_list(&mut self, id: TypeId, ty: &Type, docs: &Docs);
     fn anonymous_type_future(&mut self, id: TypeId, ty: &Option<Type>, docs: &Docs);
-    fn anonymous_type_stream(&mut self, id: TypeId, ty: &Type, docs: &Docs);
+    fn anonymous_type_stream(&mut self, id: TypeId, ty: &Option<Type>, docs: &Docs);
     fn anonymous_type_type(&mut self, id: TypeId, ty: &Type, docs: &Docs);
     fn anonymous_type_error_context(&mut self);
 

crates/core/src/lib.rs

@@ -1169,7 +1169,7 @@ impl<'a> CoreInterfaceGenerator<'a> for InterfaceGenerator<'a> {
         todo!()
     }
 
-    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Type, docs: &Docs) {
+    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Option<Type>, docs: &Docs) {
         _ = (id, name, ty, docs);
         todo!()
     }

crates/csharp/src/interface.rs

@@ -322,7 +322,7 @@ impl InterfaceGenerator<'_> {
                     TypeDefKind::Stream(t) => {
                         let mut src = String::new();
                         src.push_str("Stream");
-                        src.push_str(&self.ty_name(t));
+                        src.push_str(&self.optional_ty_name(t.as_ref()));
                         src.push('T');
                         src
                     }
@@ -1271,7 +1271,7 @@ impl<'a> wit_bindgen_core::InterfaceGenerator<'a> for InterfaceGenerator<'a> {
         todo!()
     }
 
-    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Type, docs: &Docs) {
+    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Option<Type>, docs: &Docs) {
         _ = (id, name, ty, docs);
         todo!()
     }

crates/go/src/interface.rs

@@ -342,7 +342,7 @@ impl<T> Stream for StreamReader<T> {
                             };
                             Box::pin(async move {
                                 let mut buffer = iter::repeat_with(MaybeUninit::uninit)
-                                    .take(ceiling(64 * 1024, mem::size_of::<T>()))
+                                    .take(ceiling(64 * 1024, mem::size_of::<T>().max(1)))
                                     .collect::<Vec<_>>();
 
                                 let result =

crates/guest-rust/rt/src/async_support/stream_support.rs

@@ -413,11 +413,16 @@ impl InterfaceGenerator<'_> {
                             self.push_str("future");
                         }
                     },
-                    TypeDefKind::Stream(t) => {
-                        self.push_str("stream<");
-                        self.print_ty(t);
-                        self.push_str(">");
-                    }
+                    TypeDefKind::Stream(t) => match t {
+                        Some(t) => {
+                            self.push_str("stream<");
+                            self.print_ty(t);
+                            self.push_str(">");
+                        }
+                        None => {
+                            self.push_str("stream");
+                        }
+                    },
                     TypeDefKind::ErrorContext => {
                         self.push_str("error-context");
                     }
@@ -661,7 +666,7 @@ impl<'a> wit_bindgen_core::InterfaceGenerator<'a> for InterfaceGenerator<'a> {
         todo!()
     }
 
-    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Type, docs: &Docs) {
+    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Option<Type>, docs: &Docs) {
         _ = (id, name, ty, docs);
         todo!()
     }

crates/markdown/src/lib.rs

@@ -1504,7 +1504,7 @@ impl<'a> wit_bindgen_core::InterfaceGenerator<'a> for InterfaceGenerator<'a> {
         todo!()
     }
 
-    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Type, docs: &Docs) {
+    fn type_stream(&mut self, id: TypeId, name: &str, ty: &Option<Type>, docs: &Docs) {
         _ = (id, name, ty, docs);
         todo!()
     }