diff --git a/src/crd-controller/HostedServices/V1Alpha2Controller.cs b/src/crd-controller/HostedServices/V1Alpha2Controller.cs index 030c6a4d..e71e0d22 100644 --- 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");