No need for a buffered channel. Close the channel when function exits.

kubernetes · Apr 18, 2017 · ddd9f5f · ddd9f5f
1 parent 6c4cf3c
commit ddd9f5f
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/staging/src/k8s.io/client-go/examples/informer/main.go b/staging/src/k8s.io/client-go/examples/informer/main.go
@@ -47,7 +47,6 @@ func main() {
 		panic(err)
 	}
 
-	stop := make(chan struct{}, 1)
 	source := cache.NewListWatchFromClient(
 		clientset.Core().RESTClient(),
 		"pods",
@@ -80,6 +79,9 @@ func main() {
 			DeleteFunc: delete,
 		})
 
+	stop := make(chan struct{})
+	defer close(stop)
+
 	// the controller run starts the event processing loop
 	go controller.Run(stop)