Use recover

pkg/cache/v3/simple.go

@@ -1016,9 +1016,12 @@ func (cache *snapshotCache) respondDelta(ctx context.Context, snapshot ResourceS
 			cache.log.Debugf("node: %s, sending delta response for typeURL %s with resources: %v removed resources: %v with wildcard: %t",
 				request.GetNode().GetId(), request.GetTypeUrl(), GetResourceWithTTLNames(resp.Resources), resp.RemovedResources, state.IsWildcard())
 		}
-		if value == nil {
-			return nil, nil
-		}
+
+		defer func() {
+			if r := recover(); r != nil {
+				fmt.Println("Tried to send on a closed channel")
+			}
+		}()
 		select {
 		case value <- resp:
 			return resp, nil