更简洁的使用API

Author: alafighting

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

@@ -7,11 +7,11 @@
 
 import com.im4j.kakacache.rxjava.KakaCache;
 import com.im4j.kakacache.rxjava.common.utils.LogUtils;
-import com.im4j.kakacache.rxjava.netcache.retrofit.KakaRxCallAdapterFactory;
 import com.im4j.kakacache.rxjava.netcache.strategy.FirstCacheStrategy;
 
 import retrofit2.Retrofit;
 import retrofit2.converter.gson.GsonConverterFactory;
+import rx.android.schedulers.AndroidSchedulers;
 import rx.schedulers.Schedulers;
 
 /**
@@ -37,8 +37,8 @@ protected void onCreate(@Nullable Bundle savedInstanceState) {
 
         retrofit = new Retrofit.Builder()
                 .baseUrl("https://api.github.com/")
-                .addConverterFactory(GsonConverterFactory.create(KakaCache.gson().create()))
-                .addCallAdapterFactory(KakaRxCallAdapterFactory.create())
+                .addConverterFactory(KakaCache.gsonConverter())
+                .addCallAdapterFactory(KakaCache.rxCallAdapter())
                 .build();
 
         service = retrofit.create(GitHubService.class);
@@ -60,6 +60,8 @@ protected void onCreate(@Nullable Bundle savedInstanceState) {
     void demoForNormal() {
         service.listReposForNormal("alafighting")
                 .compose(KakaCache.transformer(KEY_CACHE, new FirstCacheStrategy()))
+                .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(data -> {
                     LogUtils.log("next  data=" + data);
                 }, error -> {
@@ -75,6 +77,7 @@ void demoForNormal() {
     void demoForKaka() {
         service.listReposForKaka("alafighting")
                 .subscribeOn(Schedulers.io())
+                .observeOn(AndroidSchedulers.mainThread())
                 .subscribe(data -> {
                     LogUtils.log("listReposForKaka => "+data);
                 }, error -> {

library/build.gradle

@@ -27,9 +27,10 @@ dependencies {
     compile fileTree(dir: 'libs', include: ['*.jar'])
     testCompile 'junit:junit:4.12'
     compile 'com.android.support:appcompat-v7:24.0.0'
+    compile 'com.google.code.gson:gson:2.7'
     compile 'io.reactivex:rxandroid:1.2.1'
     compile 'com.squareup.okhttp3:okhttp:3.3.1'
     compile 'com.squareup.retrofit2:retrofit:2.1.0'
     compile 'com.squareup.retrofit2:adapter-rxjava:2.1.0'
-    compile 'com.google.code.gson:gson:2.7'
+    compile 'com.squareup.retrofit2:converter-gson:2.1.0'
 }

library/src/main/java/com/im4j/kakacache/rxjava/KakaCache.java

@@ -19,6 +19,7 @@
 import com.im4j.kakacache.rxjava.core.memory.storage.SimpleMemoryStorage;
 import com.im4j.kakacache.rxjava.manager.RxCacheManager;
 import com.im4j.kakacache.rxjava.netcache.ResultData;
+import com.im4j.kakacache.rxjava.netcache.retrofit.KakaRxCallAdapterFactory;
 import com.im4j.kakacache.rxjava.netcache.strategy.CacheStrategy;
 import com.litesuits.orm.LiteOrm;
 
@@ -27,6 +28,9 @@
 import java.lang.reflect.Type;
 import java.util.Arrays;
 
+import retrofit2.CallAdapter;
+import retrofit2.Converter;
+import retrofit2.converter.gson.GsonConverterFactory;
 import rx.Observable;
 
 /**
@@ -89,6 +93,18 @@ public static GsonBuilder gson() {
         return builder;
     }
 
+    public static Converter.Factory gsonConverter(GsonBuilder builder) {
+        builder.registerTypeAdapter(ResultData.class, new ResultDataAdapter());
+        return GsonConverterFactory.create(builder.create());
+    }
+    public static Converter.Factory gsonConverter() {
+        return gsonConverter(KakaCache.gson());
+    }
+
+    public static CallAdapter.Factory rxCallAdapter() {
+        return KakaRxCallAdapterFactory.create();
+    }
+
 
     private static class CacheTransformer<T> implements Observable.Transformer<T, ResultData<T>> {
         private String key;

library/src/main/java/com/im4j/kakacache/rxjava/core/memory/storage/SimpleMemoryStorage.java

@@ -103,4 +103,5 @@ private static long countSize(Object value) {
     public long getTotalQuantity() {
         return mStorageMap.size();
     }
+
 }