TouchInstinct
/
RoboSwag-core
304
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #21 from TouchInstinct/bugs/fix 

fixed incorrect strategy behavior
This commit is contained in:
Gavriil 2017-03-03 19:08:48 +03:00 committed by GitHub
parent e988523569 58b710d02a
commit 0b7127612b
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/main/java/ru/touchin/roboswag/core/observables/storable/Storable.java
View File

@ -151,7 +151,7 @@ public class Storable<TKey, TObject, TStoreObject> {
.subscribeOn(storeScheduler != null ? storeScheduler : Schedulers.io()) .subscribeOn(storeScheduler != null ? storeScheduler : Schedulers.io())
.concatWith(newStoreValueEvent) .concatWith(newStoreValueEvent)
.map(storeObject -> returnDefaultValueIfNull(storeObject, defaultValue)); .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 @NonNull
@ -173,7 +173,7 @@ public class Storable<TKey, TObject, TStoreObject> {
}) })
.subscribeOn(storeScheduler != null ? storeScheduler : Schedulers.computation()); .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;
} }
/** /**