ack: preparations for reconnect

Author: Keruspe

src/acknowledgement.rs

@@ -62,6 +62,10 @@ impl Acknowledgements {
     pub(crate) fn on_channel_error(&self, error: Error) {
         self.0.lock().on_channel_error(error);
     }
+
+    pub(crate) fn reset(&self, error: Error) {
+        self.0.lock().reset(error);
+    }
 }
 
 impl fmt::Debug for Acknowledgements {
@@ -174,4 +178,9 @@ impl Inner {
             }
         }
     }
+
+    fn reset(&mut self, error: Error) {
+        self.delivery_tag = IdSequence::new(false);
+        self.on_channel_error(error);
+    }
 }