in progress

cache/cachemap.go

@@ -81,6 +81,11 @@ func (s *CacheMap) EventCleaner() <-chan map[any]any {
 }
 
 func (s *CacheMap) cleanWorker() {
+	defer func() {
+		for _, v := range s.cleanChans {
+			close(v)
+		}
+	}()
 	t := time.NewTicker(s.live)
 loop:
 	for {