fix: close stream when reconciler

siyul-park · Dec 14, 2023 · f39d3b0 · f39d3b0
1 parent d1413e6
commit f39d3b0
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/loader/reconciler.go b/pkg/loader/reconciler.go
@@ -116,7 +116,9 @@ func (r *Reconciler) watch(ctx context.Context) (*storage.Stream, error) {
 			r.mu.Lock()
 			defer r.mu.Unlock()
 
-			r.stream = nil
+			if r.stream == s {
+				r.stream = nil
+			}
 		case <-r.done:
 			return
 		}