diff --git a/amqprs/src/net/reader_handler.rs b/amqprs/src/net/reader_handler.rs
index 442a991..d385125 100644
--- a/amqprs/src/net/reader_handler.rs
+++ b/amqprs/src/net/reader_handler.rs
@@ -254,6 +254,7 @@ impl ReaderHandler {
                 res = self.stream.read_frame() => {
                     // any frame can be considered as heartbeat
                     expiration = time::Instant::now() + time::Duration::from_secs(max_interval);
+                    heartbeat_miss = 0;
                     #[cfg(feature="traces")]
                     trace!("server heartbeat deadline is updated to {:?}", expiration);