Commit 0d189f5f by sikang

bug fix bindligecycle

parent 8eef628a
......@@ -43,17 +43,17 @@ public class BasePresenter<T> {
* 处理请求
*/
protected <T> void handleRequest(Observable<T> observable, Observer<T> observer) {
observable = view == null ? observable : observable.compose(view.bindToLifecycle());
observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.compose(view.<T>bindToLifecycle())
.subscribe(observer);
}
protected <T> void handleRequest(final String action, Observable<T> observable) {
observable = view == null ? observable : observable.compose(view.bindToLifecycle());
observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.compose(view.<T>bindToLifecycle())
.subscribe(new HttpObserver<T>(action) {
@Override
public void onStart() {
......@@ -126,8 +126,8 @@ public class BasePresenter<T> {
@SuppressLint("CheckResult")
private void bindLifecycle(Consumer consumer) {
Observable.just(true)
.observeOn(AndroidSchedulers.mainThread())
Observable observable = view == null ? Observable.just(true) : Observable.just(true).compose(view.bindToLifecycle());
observable.observeOn(AndroidSchedulers.mainThread())
.compose(view.<Boolean>bindToLifecycle())
.subscribe(consumer);
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment