wip

ntex-rs · Apr 9, 2024 · 548627d · 548627d
1 parent 201813a
commit 548627d
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/src/delivery.rs b/src/delivery.rs
@@ -134,6 +134,10 @@ impl Delivery {
     }
 
     pub async fn wait(&self) -> Result<Option<DeliveryState>, AmqpProtocolError> {
+        if self.0.flags.get().contains(Flags::LOCAL_SETTLED) {
+            return Ok(None);
+        }
+
         let rx = if let Some(inner) = self
             .session
             .inner