From 5ea931a2284e0302a922cd9e1973c3b900e43fb3 Mon Sep 17 00:00:00 2001 From: atauov Date: Thu, 12 Mar 2026 15:53:10 +0500 Subject: [PATCH] fix defer closure --- statefun/cache/cache.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/statefun/cache/cache.go b/statefun/cache/cache.go index aeb17400..e27936cd 100644 --- a/statefun/cache/cache.go +++ b/statefun/cache/cache.go @@ -509,7 +509,9 @@ func NewCacheStore(ctx context.Context, cacheConfig *Config, js nats.JetStreamCo system.GlobalPrometrics.GetRoutinesCounter().Started("cache.storeUpdatesHandler") defer system.GlobalPrometrics.GetRoutinesCounter().Stopped("cache.storeUpdatesHandler") if w, err := kv.Watch(cacheConfig.kvStorePrefix+".>", nats.IgnoreDeletes()); err == nil { - defer system.MsgOnErrorReturn(w.Stop()) + defer func() { + system.MsgOnErrorReturn(w.Stop()) + }() activeKVSync := true for activeKVSync { select {