informer/reflector: delete syncWithStream

Signed-off-by: Iceber Gu <caiwei95@hotmail.com>

pkg/synchromanager/clustersynchro/informer/reflector.go

@@ -479,8 +479,16 @@ func (r *Reflector) listWithResultStream(ctx context.Context, pager *clspager.Li
 	go func() {
 		list, paginatedResult, err = pager.List(clspager.WithResultStream(ctx, ch), options)
 	}()
-	if itemKeys, err = r.syncWithStream(ch); err != nil {
-		return
+
+	var key string
+	for obj := range ch {
+		if key, err = cache.DeletionHandlingMetaNamespaceKeyFunc(obj); err != nil {
+			return
+		}
+		if err = r.store.Add(obj); err != nil {
+			return
+		}
+		itemKeys = append(itemKeys, cache.ExplicitKey(key))
 	}
 	return
 }
@@ -494,21 +502,6 @@ func (r *Reflector) syncWith(items []runtime.Object, resourceVersion string) err
 	return r.store.Replace(found, resourceVersion)
 }
 
-func (r *Reflector) syncWithStream(ch chan runtime.Object) ([]interface{}, error) {
-	var keys []interface{}
-	for obj := range ch {
-		key, err := cache.DeletionHandlingMetaNamespaceKeyFunc(obj)
-		if err != nil {
-			return keys, err
-		}
-		keys = append(keys, cache.ExplicitKey(key))
-		if err := r.store.Add(obj); err != nil {
-			return keys, err
-		}
-	}
-	return keys, nil
-}
-
 func (r *Reflector) syncWithKeys(keys []interface{}, resourceVersion string) error {
 	return r.store.Replace(keys, resourceVersion)
 }