Send list before ever calling Watch

vendor/github.com/rancher/norman/pkg/store/proxy/proxy_store.go

@@ -1,7 +1,6 @@
 package proxy
 
 import (
-	"context"
 	"sync"
 
 	"github.com/rancher/norman/pkg/types"
@@ -119,35 +118,33 @@ func (s *Store) Watch(apiOp *types.APIRequest, schema *types.Schema, opt *types.
 		return nil, err
 	}
 
-	timeout := int64(60 * 30)
-	watcher, err := k8sClient.Watch(metav1.ListOptions{
-		Watch:           true,
-		TimeoutSeconds:  &timeout,
-		ResourceVersion: list.GetResourceVersion(),
-	})
-	if err != nil {
-		return nil, err
-	}
-
-	watchingContext, cancelWatchingContext := context.WithCancel(apiOp.Request.Context())
-	go func() {
-		<-watchingContext.Done()
-		logrus.Debugf("stopping watcher for %s", schema.ID)
-		watcher.Stop()
-	}()
-
 	result := make(chan types.APIEvent)
 	go func() {
+		defer func() {
+			logrus.Debugf("closing watcher for %s", schema.ID)
+			close(result)
+		}()
+
 		for i, obj := range list.Items {
 			result <- s.toAPIEvent(apiOp, schema, i, len(list.Items), false, &obj)
 		}
+
+		timeout := int64(60 * 30)
+		watcher, err := k8sClient.Watch(metav1.ListOptions{
+			Watch:           true,
+			TimeoutSeconds:  &timeout,
+			ResourceVersion: list.GetResourceVersion(),
+		})
+		if err != nil {
+			logrus.Debugf("stopping watch for %s: %v", schema.ID, err)
+			return
+		}
+		defer watcher.Stop()
+
 		for event := range watcher.ResultChan() {
 			data := event.Object.(*unstructured.Unstructured)
 			result <- s.toAPIEvent(apiOp, schema, 0, 0, event.Type == watch.Deleted, data)
 		}
-		logrus.Debugf("closing watcher for %s", schema.ID)
-		close(result)
-		cancelWatchingContext()
 	}()
 
 	return result, nil