From e707837bf5c0179748ed672cb14808c978c3a960 Mon Sep 17 00:00:00 2001 From: Drewster727 Date: Fri, 8 Apr 2016 10:31:49 -0500 Subject: [PATCH] #150 split out the cache subscriptions to make sure they subscribe properly --- PlexRequests.Services/MediaCacheService.cs | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) diff --git a/PlexRequests.Services/MediaCacheService.cs b/PlexRequests.Services/MediaCacheService.cs index 7633fc97f..48799f5b6 100644 --- a/PlexRequests.Services/MediaCacheService.cs +++ b/PlexRequests.Services/MediaCacheService.cs @@ -66,18 +66,22 @@ namespace PlexRequests.Services private ICouchPotatoCacher CpCacher { get; } private ISonarrCacher SonarrCacher { get; } private ISickRageCacher SickRageCacher { get; } - private IDisposable UpdateSubscription { get; set; } + private IDisposable CpSubscription { get; set; } + private IDisposable SonarrSubscription { get; set; } + private IDisposable SickRageSubscription { get; set; } public void Start(Configuration c) { - UpdateSubscription?.Dispose(); + CpSubscription?.Dispose(); + SonarrSubscription?.Dispose(); + SickRageSubscription?.Dispose(); Task.Factory.StartNew(() => CpCacher.Queued(-1)); Task.Factory.StartNew(() => SonarrCacher.Queued(-1)); Task.Factory.StartNew(() => SickRageCacher.Queued(-1)); - UpdateSubscription = Observable.Interval(c.Intervals.Notification).Subscribe(CpCacher.Queued); - UpdateSubscription = Observable.Interval(c.Intervals.Notification).Subscribe(SonarrCacher.Queued); - UpdateSubscription = Observable.Interval(c.Intervals.Notification).Subscribe(SickRageCacher.Queued); + CpSubscription = Observable.Interval(c.Intervals.Notification).Subscribe(CpCacher.Queued); + SonarrSubscription = Observable.Interval(c.Intervals.Notification).Subscribe(SonarrCacher.Queued); + SickRageSubscription = Observable.Interval(c.Intervals.Notification).Subscribe(SickRageCacher.Queued); } public void Execute()