From 97628b130721cf6b89c98e6b1ca97452a348a292 Mon Sep 17 00:00:00 2001 From: PavelAgarkov Date: Mon, 27 Oct 2025 22:01:07 +0600 Subject: [PATCH] add final call runCancel() on end of Stop() --- queue.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/queue.go b/queue.go index ac6f981..3fdcf19 100644 --- a/queue.go +++ b/queue.go @@ -538,6 +538,10 @@ func (q *RateEnvelopeQueue) Stop() { q.setState(StateStopped) q.lifecycleMu.Unlock() + if runCancel != nil { + runCancel() + } + q.queueMu.Lock() q.queue = nil q.queueMu.Unlock()