delete from subs

waku-org · Mar 11, 2024 · 682410e · 682410e
1 parent 1436294
commit 682410e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/waku/v2/api/filter.go b/waku/v2/api/filter.go
@@ -88,6 +88,9 @@ func (apiSub *Sub) checkAliveness() map[string]uint {
 
 			if err != nil {
 				subDetails.Close()
+				apiSub.Lock()
+				defer apiSub.Unlock()
+				delete(apiSub.subs, subDetails.ID)
 			} else {
 				ch <- subDetails.ContentFilter.PubsubTopic
 			}