fix(rs-wit-bindgen): do not fail on async I/O errors

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

Author: rvolosatovs

Cargo.lock

@@ -127,9 +127,9 @@ wasmtime = { version = "22", default-features = false }
 wasmtime-wasi = { version = "22", default-features = false }
 wit-bindgen = { version = "0.27", default-features = false }
 wit-bindgen-core = { version = "0.27", default-features = false }
-wit-bindgen-wrpc = { version = "0.4", default-features = false, path = "./crates/wit-bindgen" }
+wit-bindgen-wrpc = { version = "0.4.1", default-features = false, path = "./crates/wit-bindgen" }
 wit-bindgen-wrpc-go = { version = "0.2", default-features = false, path = "./crates/wit-bindgen-go" }
-wit-bindgen-wrpc-rust = { version = "0.4", default-features = false, path = "./crates/wit-bindgen-rust" }
+wit-bindgen-wrpc-rust = { version = "0.4.1", default-features = false, path = "./crates/wit-bindgen-rust" }
 wit-bindgen-wrpc-rust-macro = { version = "0.4", default-features = false, path = "./crates/wit-bindgen-rust-macro" }
 wit-component = { version = "0.212", default-features = false }
 wit-parser = { version = "0.212", default-features = false }

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "wit-bindgen-wrpc-rust"
-version = "0.4.0"
+version = "0.4.1"
 description = """
 Rust bindings generator for wRPC, typically used through
 the `wit-bindgen-wrpc` crate's `generate!` macro.

crates/wit-bindgen-rust/Cargo.toml

@@ -337,30 +337,32 @@ pub async fn serve_interface<T: {wrpc_transport}::Serve, U>(
                 self.src,
                 r#"
                         ).await {{
-                            Ok(returns) => {{
+                            Ok(results) => {{
                                 match tx("#,
             );
             if func.results.len() == 1 {
-                // wrap single-element returns into a tuple for correct indexing
-                self.push_str("(returns,)");
+                // wrap single-element results into a tuple for correct indexing
+                self.push_str("(results,)");
             } else {
-                self.push_str("returns");
+                self.push_str("results");
             }
             uwrite!(
                 self.src,
                 r#"
                                 ).await {{
                                     Ok(()) => {{
                                         if let Some(rx) = rx {{
-                                            rx.await??;
+                                            if let Err(err) = rx.await? {{
+                                                {tracing}::warn!(?err, "failed to receive async `{instance}.{wit_name}` invocation parameters");
+                                            }}
                                         }}
                                         continue;
                                     }}
                                     Err(err) => {{
                                         if let Some(rx) = rx {{
                                             rx.abort();
                                         }}
-                                        {tracing}::warn!(?err, "failed to send returns");
+                                        {tracing}::warn!(?err, "failed to transmit `{instance}.{wit_name}` invocation results");
                                     }}
                                 }}
                             }},

crates/wit-bindgen-rust/src/interface.rs

@@ -1,6 +1,6 @@
 [package]
 name = "wit-bindgen-wrpc"
-version = "0.4.0"
+version = "0.4.1"
 description = """
 Rust bindings generator for wRPC.
 """