From 74db004f514f3ff8afad4347573f8fd4608aef6c Mon Sep 17 00:00:00 2001 From: Vasiliy Tolstov Date: Fri, 15 Apr 2022 15:50:45 +0300 Subject: [PATCH] server: fix race in noop server Signed-off-by: Vasiliy Tolstov --- server/noop.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/noop.go b/server/noop.go index 3ebd02b1..bd4d3f69 100644 --- a/server/noop.go +++ b/server/noop.go @@ -277,7 +277,7 @@ func (n *noopServer) Deregister() error { wg := sync.WaitGroup{} for sb, subs := range n.subscribers { - for _, sub := range subs { + for idx := range subs { if sb.Options().Context != nil { cx = sb.Options().Context } @@ -293,7 +293,7 @@ func (n *noopServer) Deregister() error { config.Logger.Errorf(n.opts.Context, "unsubscribing from topic: %s err: %v", s.Topic(), err) } } - }(sub) + }(subs[idx]) } n.subscribers[sb] = nil }