Close the channel earlier

Signed-off-by: Richard Wall <richard.wall@jetstack.io>
kubernetes-sigs · Feb 3, 2022 · 0359498 · 0359498
1 parent b1d9a16
commit 0359498
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/cache/internal/informers_map.go b/pkg/cache/internal/informers_map.go
@@ -434,12 +434,12 @@ func (w *gvkFixupWatcher) run() {
 		w.ch <- e
 	}
 	w.wg.Done()
+	close(w.ch)
 }
 
 func (w *gvkFixupWatcher) Stop() {
 	w.watcher.Stop()
 	w.wg.Wait()
-	close(w.ch)
 }
 
 func (w *gvkFixupWatcher) ResultChan() <-chan watch.Event {