From d9ce920d040164ce20ceef7cdb1c0ff6008ff3e6 Mon Sep 17 00:00:00 2001 From: Skye Gill Date: Wed, 23 Nov 2022 13:36:37 +0000 Subject: [PATCH] defer RUnlock Signed-off-by: Skye Gill --- pkg/service/connect_service.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/service/connect_service.go b/pkg/service/connect_service.go index 1aea0faa2..a089c67dc 100644 --- a/pkg/service/connect_service.go +++ b/pkg/service/connect_service.go @@ -185,10 +185,10 @@ func (s *ConnectService) EventStream( func (s *ConnectService) Notify(n Notification) { s.eventingConfiguration.mu.RLock() + defer s.eventingConfiguration.mu.RUnlock() for _, send := range s.eventingConfiguration.subs { send <- n } - s.eventingConfiguration.mu.RUnlock() } func (s *ConnectService) ResolveBoolean(