|
|
@@ -14,24 +14,22 @@ import io.reactivex.observers.DisposableObserver;
|
|
|
* 用于可见,可手动取消的网络任务
|
|
|
*/
|
|
|
public abstract class MvpObserver<T> extends DisposableObserver<T> {
|
|
|
- private boolean mWithLoading;
|
|
|
private BasePresenter<?> mPresenter;
|
|
|
|
|
|
- public MvpObserver(final BasePresenter<?> presenter) {
|
|
|
- this(presenter, false);
|
|
|
+ public MvpObserver() {
|
|
|
+ this(null);
|
|
|
}
|
|
|
|
|
|
- public MvpObserver(final BasePresenter<?> presenter, final boolean withLoading) {
|
|
|
- mWithLoading = withLoading;
|
|
|
+ public MvpObserver(final BasePresenter<?> presenter) {
|
|
|
mPresenter = presenter;
|
|
|
- if (mPresenter != null && withLoading) {
|
|
|
+ if (mPresenter != null) {
|
|
|
presenter.showProgress();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
@Override
|
|
|
public void onNext(T t) {
|
|
|
- if (mPresenter != null && mWithLoading) {
|
|
|
+ if (mPresenter != null) {
|
|
|
mPresenter.hideProgress();
|
|
|
}
|
|
|
onSuccess(Code.SUCCESS, t);
|
|
|
@@ -42,7 +40,7 @@ public abstract class MvpObserver<T> extends DisposableObserver<T> {
|
|
|
|
|
|
@Override
|
|
|
public void onError(Throwable e) {
|
|
|
- if (mWithLoading) {
|
|
|
+ if (mPresenter != null) {
|
|
|
mPresenter.hideProgress();
|
|
|
}
|
|
|
e.printStackTrace();
|