Remove unwrap from consumer

Although those unwraps seem safe, it's still better not not have app panicking at all. Even in case of those somehow failing, client will recover by itself on next iteration of the timer. Signed-off-by: Tomasz Pietrek <[email protected]>
nats-io · Aug 26, 2024 · 2634d01 · 2634d01
1 parent ed856c9
commit 2634d01
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/async-nats/src/jetstream/consumer/pull.rs b/async-nats/src/jetstream/consumer/pull.rs
@@ -961,7 +961,7 @@ impl Stream {
                                 .into()
                         }))
                         .await
-                        .unwrap();
+                        .ok();
                     trace!("result send over tx");
                 }
             }
@@ -1092,7 +1092,7 @@ impl futures::Stream for Stream {
                 && !self.pending_request
             {
                 debug!("pending messages reached threshold to send new fetch request");
-                self.request_tx.send(()).unwrap();
+                self.request_tx.send(()).ok();
                 self.pending_request = true;
             }