钥匙柜

weimingfei

24 分钟以前 32f1fab3ce19db6539030c5e574212552a3f3abc

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
package com.doumee.lib_coremodel.http.rxJava;
 
import java.lang.ref.WeakReference;
 
import io.reactivex.Observer;
import io.reactivex.disposables.Disposable;
 
public abstract class SimpleObserver<T> implements Observer<T> {
    private RxJavaGcManager rxJavaGcManager;
    private WeakReference<Disposable> sr;
 
    public SimpleObserver(RxJavaGcManager rxJavaGcManager) {
        this.rxJavaGcManager = rxJavaGcManager;
    }
 
    @Override
    public void onSubscribe(Disposable d) {
        rxJavaGcManager.addDisposable(d);
        sr=new WeakReference<Disposable>(d);
    }
 
    @Override
    public void onComplete(){
        if(sr.get()!=null){
            rxJavaGcManager.disposableActive(sr.get());
        }
    }
}