From f6578fe443b21e6a80e36940910ad8e55acfe060 Mon Sep 17 00:00:00 2001
From: "flamingo[bot]" <277372822+flamingo[bot]@users.noreply.github.com>
Date: Mon, 24 Aug 2026 05:09:40 +0000
Subject: [PATCH] fix(NATSRS-002): publish() unwrap() panics on send failure
 instead of propagating an error

---
 async-nats/src/jetstream/consumer/push.rs | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/async-nats/src/jetstream/consumer/push.rs b/async-nats/src/jetstream/consumer/push.rs
index 327807170..d9075e37e 100644
--- a/async-nats/src/jetstream/consumer/push.rs
+++ b/async-nats/src/jetstream/consumer/push.rs
@@ -153,10 +153,15 @@ impl futures_util::Stream for Messages {
                                     // TODO store pending_publish as a future and return errors from it
                                     let client = self.context.client.clone();
                                     tokio::task::spawn(async move {
-                                        client
+                                        if let Err(err) = client
                                             .publish(subject, Bytes::from_static(b""))
                                             .await
-                                            .unwrap();
+                                        {
+                                            tracing::warn!(
+                                                "failed to respond to idle heartbeat: {}",
+                                                err
+                                            );
+                                        }
                                     });
                                 }