Insert the latest version returned in GetAndFetchLatest into the cache

reactiveui · Dec 30, 2011 · 7ea4467 · 7ea4467
1 parent c634f6c
commit 7ea4467
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/Akavache/BlobCacheExtensions.cs b/Akavache/BlobCacheExtensions.cs
@@ -114,7 +114,8 @@ public static IObservable<T> GetOrFetchObject<T>(this IBlobCache This, string ke
         public static IObservable<T> GetAndFetchLatest<T>(this IBlobCache This, string key, Func<IObservable<T>> fetchFunc, DateTimeOffset? absoluteExpiration = null)
         {
             var fail = Observable.Defer(() => fetchFunc())
-                .Finally(() => This.Invalidate(key));
+                .Finally(() => This.Invalidate(key))
+                .Do(x => This.InsertObject(key, x, absoluteExpiration));
 
             var result = This.GetObjectAsync<T>(key).Select(x => new Tuple<T, bool>(x, true))
                 .Catch(Observable.Return(new Tuple<T, bool>(default(T), false)));
@@ -124,7 +125,7 @@ public static IObservable<T> GetAndFetchLatest<T>(this IBlobCache This, string k
                 return x.Item2 ?
                     Observable.Return(x.Item1) :
                     Observable.Empty<T>();
-            }).Concat(fail);
+            }).Concat(fail).Multicast(new AsyncSubject<T>()).RefCount();
         }
 
         static string GetTypePrefixedKey(string key, Type type)