支持更多的缓存策略

Author: alafighting

app/src/main/java/com/im4j/kakacache/rxjava/demo/MainActivity.java

@@ -7,10 +7,13 @@
 import android.widget.Button;
 
 import com.im4j.kakacache.rxjava.netcache.RxRemoteCache;
-import com.im4j.kakacache.rxjava.netcache.strategy.FirstCacheStrategy;
+import com.im4j.kakacache.rxjava.netcache.strategy.CacheAndRemoteStrategy;
 
 import java.util.concurrent.TimeUnit;
 
+import rx.Observable;
+import rx.Subscriber;
+
 /**
  * Demo主界面
  * @version alafighting 2016-06
@@ -27,7 +30,7 @@ protected void onCreate(@Nullable Bundle savedInstanceState) {
 
         btnTest = (Button) findViewById(R.id.btn_test_cache);
         btnTest.setOnClickListener(view -> {
-            remote().compose(RxRemoteCache.transformer(KEY_CACHE, new FirstCacheStrategy())).subscribe(data -> {
+            remote().compose(RxRemoteCache.transformer(KEY_CACHE, new CacheAndRemoteStrategy())).subscribe(data -> {
                 Log.e("main", "next  data=" + data);
             }, error -> {
                 Log.e("main", "error", error);
@@ -38,7 +41,14 @@ protected void onCreate(@Nullable Bundle savedInstanceState) {
     }
 
     private rx.Observable<String> remote() {
-        return rx.Observable.just("test remote").delay(3, TimeUnit.SECONDS);
+        return Observable.create(new Observable.OnSubscribe<String>() {
+            @Override
+            public void call(Subscriber<? super String> subscriber) {
+                Log.e("main", "loadRemote");
+                subscriber.onNext("test remote");
+                subscriber.onCompleted();
+            }
+        }).delay(3, TimeUnit.SECONDS);
     }
 
 }

library/src/main/java/com/im4j/kakacache/rxjava/netcache/strategy/CacheAndRemoteStrategy.java

@@ -0,0 +1,22 @@
+package com.im4j.kakacache.rxjava.netcache.strategy;
+
+import com.im4j.kakacache.rxjava.netcache.ResultData;
+
+import rx.Observable;
+import rx.schedulers.Schedulers;
+
+/**
+ * 先缓存，后网络
+ * @version alafighting 2016-06
+ */
+public class CacheAndRemoteStrategy<T> extends BasicCacheStrategy<T> {
+
+    @Override
+    public Observable<ResultData<T>> execute(String key, Observable source) {
+        return Observable.concat(
+                loadCache(key),
+                loadRemote(key, source)
+        ).subscribeOn(Schedulers.io());
+    }
+
+}

library/src/main/java/com/im4j/kakacache/rxjava/netcache/strategy/FirstCacheStrategy.java

@@ -6,7 +6,7 @@
 import rx.schedulers.Schedulers;
 
 /**
- * 谁先响应，处理谁
+ * 优先缓存
  * @version alafighting 2016-06
  */
 public class FirstCacheStrategy<T> extends BasicCacheStrategy<T> {
@@ -16,7 +16,7 @@ public Observable<ResultData<T>> execute(String key, Observable source) {
         return Observable.concat(
                 loadCache(key),
                 loadRemote(key, source)
-        ).firstOrDefault(null, it -> ((ResultData<T>)it.data) != null).subscribeOn(Schedulers.io());
+        ).firstOrDefault(null, it -> ((ResultData<T>)it).data != null).subscribeOn(Schedulers.io());
     }
 
 }

library/src/main/java/com/im4j/kakacache/rxjava/netcache/strategy/FirstRemoteStrategy.java

@@ -0,0 +1,22 @@
+package com.im4j.kakacache.rxjava.netcache.strategy;
+
+import com.im4j.kakacache.rxjava.netcache.ResultData;
+
+import rx.Observable;
+import rx.schedulers.Schedulers;
+
+/**
+ * 优先服务器
+ * @version alafighting 2016-06
+ */
+public class FirstRemoteStrategy<T> extends BasicCacheStrategy<T> {
+
+    @Override
+    public Observable<ResultData<T>> execute(String key, Observable source) {
+        return Observable.concat(
+                loadRemote(key, source),
+                loadCache(key)
+        ).firstOrDefault(null, it -> ((ResultData<T>)it).data != null).subscribeOn(Schedulers.io());
+    }
+
+}