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());
|
}
|
}
|
}
|
