fix

canonical · Dec 11, 2024 · 02355c1 · 02355c1
1 parent 8eff9d8
commit 02355c1
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/pkg/kine/server/watch.go b/pkg/kine/server/watch.go
@@ -124,12 +124,7 @@ func (w *watcher) Start(ctx context.Context, r *etcdserverpb.WatchCreateRequest)
 
 			// Wait for events or progress notifications
 			select {
-			case events, ok := <-wr.Events:
-				if !ok {
-					// Channel was closed, break out of the loop
-					outer = false
-					break
-				}
+			case events = <-wr.Events:
 				// We received events; batch any additional queued events
 				reads++
 				inner := true