新增不绑定生命周期方法

lannaican · Jun 8, 2020 · f0ee1a5 · f0ee1a5
1 parent 1d7e2ee
commit f0ee1a5
Showing 1 changed file with 15 additions and 2 deletions.
diff --git a/api/src/main/java/com/star/api/adapter/CallBack.java b/api/src/main/java/com/star/api/adapter/CallBack.java
@@ -1,12 +1,12 @@
 package com.star.api.adapter;
 
 import com.star.api.APIManager;
-import com.star.api.resolver.ServiceResolver;
 import com.star.api.adapter.callback.Cancel;
 import com.star.api.adapter.callback.Complete;
 import com.star.api.adapter.callback.Fail;
 import com.star.api.adapter.callback.Success;
 import com.star.api.lifecycle.LifecycleManager;
+import com.star.api.resolver.ServiceResolver;
 
 import io.reactivex.Observable;
 import io.reactivex.Observer;
@@ -33,6 +33,9 @@ public class CallBack<T> implements Observer<T> {
 
     private Disposable disposable;
 
+    //不绑定生命周期
+    private boolean unbindLife;
+
     public CallBack(Observable<T> observable) {
         this.observable = observable;
     }
@@ -99,6 +102,14 @@ public CallBack<T> setResolver(ServiceResolver<T> resolver) {
         return this;
     }
 
+    /**
+     * 独立生命周期
+     */
+    public CallBack<T> setUnbindLife(boolean unbindLife) {
+        this.unbindLife = unbindLife;
+        return this;
+    }
+
     /**
      * 执行
      */
@@ -150,7 +161,9 @@ public void cancel() {
     @Override
     public void onSubscribe(Disposable d) {
         disposable = d;
-        LifecycleManager.getInstance().add(d);
+        if (!unbindLife) {
+            LifecycleManager.getInstance().add(d);
+        }
         if (listener != null) {
             listener.onStart(this);
         }