From c18482b242729f8ff173be4e1a379d63c516deb7 Mon Sep 17 00:00:00 2001 From: rene <41963722+renaynay@users.noreply.github.com> Date: Wed, 17 Apr 2024 14:28:25 +0200 Subject: [PATCH] fix(core): Unsubscribe from new block evt on stop in listener --- core/listener.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/core/listener.go b/core/listener.go index 08e36d941f..885d19b18a 100644 --- a/core/listener.go +++ b/core/listener.go @@ -109,7 +109,12 @@ func (cl *Listener) Start(context.Context) error { } // Stop stops the listener loop. -func (cl *Listener) Stop(context.Context) error { +func (cl *Listener) Stop(ctx context.Context) error { + err := cl.fetcher.UnsubscribeNewBlockEvent(ctx) + if err != nil { + log.Warnw("listener: unsubscribing from new block event", "err", err) + } + cl.cancel() cl.cancel = nil return cl.metrics.Close()