fix(rt-wasmtime): do not error on shutdown failure

Signed-off-by: Roman Volosatovs <rvolosatovs@riseup.net>

Author: rvolosatovs

Cargo.lock

@@ -138,8 +138,8 @@ wit-component = { version = "0.215", default-features = false }
 wit-parser = { version = "0.215", default-features = false }
 wrpc-cli = { version = "0.2.1", path = "./crates/cli", default-features = false }
 wrpc-introspect = { version = "0.3", default-features = false, path = "./crates/introspect" }
-wrpc-runtime-wasmtime = { version = "0.20", path = "./crates/runtime-wasmtime", default-features = false }
+wrpc-runtime-wasmtime = { version = "0.20.1", path = "./crates/runtime-wasmtime", default-features = false }
 wrpc-transport = { version = "0.26.7", path = "./crates/transport", default-features = false }
 wrpc-transport-nats = { version = "0.22.3", path = "./crates/transport-nats", default-features = false }
 wrpc-transport-quic = { version = "0.1.1", path = "./crates/transport-quic", default-features = false }
-wrpc-wasmtime-nats-cli = { version = "0.5", path = "./crates/wasmtime-nats-cli", default-features = false }
+wrpc-wasmtime-nats-cli = { version = "0.5.1", path = "./crates/wasmtime-nats-cli", default-features = false }

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "wrpc-runtime-wasmtime"
-version = "0.20.0"
+version = "0.20.1"
 description = "wRPC wasmtime integration"
 
 authors.workspace = true

crates/runtime-wasmtime/Cargo.toml

@@ -1095,10 +1095,15 @@ where
                     )
                     .await
                     .context("failed to write asynchronous parameters")?;
-                    pin!(outgoing)
-                        .shutdown()
+                    let mut outgoing = pin!(outgoing);
+                    outgoing
+                        .flush()
                         .await
-                        .context("failed to shutdown outgoing stream")
+                        .context("failed to flush outgoing stream")?;
+                    if let Err(err) = outgoing.shutdown().await {
+                        trace!(?err, "failed to shutdown outgoing stream")
+                    }
+                    anyhow::Ok(())
                 };
                 let rx = async {
                     let mut incoming = pin!(incoming);
@@ -1172,9 +1177,12 @@ where
     tx.write_all(&buf)
         .await
         .context("failed to transmit results")?;
-    tx.shutdown()
+    tx.flush()
         .await
-        .context("failed to shutdown outgoing stream")?;
+        .context("failed to flush outgoing stream")?;
+    if let Err(err) = tx.shutdown().await {
+        trace!(?err, "failed to shutdown outgoing stream")
+    }
     try_join_all(
         zip(0.., deferred)
             .filter_map(|(i, f)| f.map(|f| (tx.index(&[i]), f)))

crates/runtime-wasmtime/src/lib.rs

@@ -1,6 +1,6 @@
 [package]
 name = "wrpc-wasmtime-nats-cli"
-version = "0.5.0"
+version = "0.5.1"
 description = "wRPC Wasmtime NATS CLI"
 
 authors.workspace = true