First subscribe again, then dispose

Soluto · Mar 29, 2021 · a5d8b28 · a5d8b28
1 parent 2596ec9
commit a5d8b28
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/crd-controller/HostedServices/V1Alpha2Controller.cs b/src/crd-controller/HostedServices/V1Alpha2Controller.cs
@@ -76,8 +76,9 @@ public Task StartAsync(CancellationToken token)
             mSubscription = ObserveKamusSecret(token);
             Observable.Interval(TimeSpan.FromSeconds(mReconciliationIntervalInSeconds)).Subscribe((s) =>
             {
-                mSubscription.Dispose();
+                var oldSubscription = mSubscription;
                 mSubscription = ObserveKamusSecret(token);
+                oldSubscription.Dispose();
             });
 
             mLogger.Information("Starting watch for KamusSecret V1Alpha2 events");