Merge remote-tracking branch 'origin/main'

* origin/main: fixed that reconnect example code actually panics and cannot really do recovery .
amqp-rs · Jul 14, 2023 · f3fdbc4 · f3fdbc4
2 parents 5fc73de + 44c0e8f
commit f3fdbc4
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/examples/reconnect.rs b/examples/reconnect.rs
@@ -50,9 +50,10 @@ async fn rabbit_stuff(addr: String) -> Result<()> {
     async_global_executor::spawn(async move {
         info!("will consume");
         while let Some(delivery) = consumer.next().await {
-            let delivery = delivery.expect("error in consumer");
-            delivery.ack(BasicAckOptions::default()).await.expect("ack");
+            let delivery = delivery?;
+            delivery.ack(BasicAckOptions::default()).await?;
         }
+        Ok::<(), lapin::Error>(())
     })
     .detach();