diff --git a/crates/channel/src/aptos_channel.rs b/crates/channel/src/aptos_channel.rs index cc1d15a8b3732..f4a2298463234 100644 --- a/crates/channel/src/aptos_channel.rs +++ b/crates/channel/src/aptos_channel.rs @@ -240,6 +240,9 @@ pub fn new( ) -> (Sender, Receiver) { let max_queue_size_per_key = NonZeroUsize!(max_queue_size_per_key, "aptos_channel cannot be of size 0"); + if let Some(counters) = counters { + counters.reset(); + } let shared_state = Arc::new(Mutex::new(SharedState { internal_queue: PerKeyQueue::new(queue_style, max_queue_size_per_key, counters), waker: None,