From 58b710d02a7aa7f179682007ba94a29380082129 Mon Sep 17 00:00:00 2001
From: Anton Domnikov <anton.domnikov@touchin.ru>
Date: Fri, 3 Mar 2017 18:15:34 +0300
Subject: [PATCH] fixed incorrect strategy behavior

---
 .../touchin/roboswag/core/observables/storable/Storable.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/ru/touchin/roboswag/core/observables/storable/Storable.java b/src/main/java/ru/touchin/roboswag/core/observables/storable/Storable.java
index 5c82a05..fe10134 100644
--- a/src/main/java/ru/touchin/roboswag/core/observables/storable/Storable.java
+++ b/src/main/java/ru/touchin/roboswag/core/observables/storable/Storable.java
@@ -151,7 +151,7 @@ public class Storable<TKey, TObject, TStoreObject> {
                 .subscribeOn(storeScheduler != null ? storeScheduler : Schedulers.io())
                 .concatWith(newStoreValueEvent)
                 .map(storeObject -> returnDefaultValueIfNull(storeObject, defaultValue));
-        return observeStrategy == ObserveStrategy.CACHE_STORE_VALUE ? result : result.replay(1).refCount();
+        return observeStrategy == ObserveStrategy.CACHE_STORE_VALUE ? result.replay(1).refCount() : result;
     }
 
     @NonNull
@@ -173,7 +173,7 @@ public class Storable<TKey, TObject, TStoreObject> {
                 })
                 .subscribeOn(storeScheduler != null ? storeScheduler : Schedulers.computation());
 
-        return observeStrategy == ObserveStrategy.CACHE_ACTUAL_VALUE ? result : result.replay(1).refCount();
+        return observeStrategy == ObserveStrategy.CACHE_ACTUAL_VALUE ? result.replay(1).refCount() : result;
     }
 
     /**