diff --git a/store/src/main/java/com/nytimes/android/external/store3/base/impl/room/RealStoreRoom.java b/store/src/main/java/com/nytimes/android/external/store3/base/impl/room/RealStoreRoom.java index 8c93cd2b..b3f987f7 100644 --- a/store/src/main/java/com/nytimes/android/external/store3/base/impl/room/RealStoreRoom.java +++ b/store/src/main/java/com/nytimes/android/external/store3/base/impl/room/RealStoreRoom.java @@ -114,7 +114,7 @@ Observable readDisk(@Nonnull final Key key) { && StoreUtil.persisterIsStale(key, persister)) { backfillCache(key); } - }).cache(); + }).replay(1); } @SuppressWarnings("CheckReturnValue") @@ -170,7 +170,7 @@ Observable response(@Nonnull final Key key) { return Observable.error(throwable); }) .doAfterTerminate(() -> inFlightRequests.invalidate(key)) - .cache(); + .replay(1); }