|
@@ -69,6 +69,8 @@ public class SimpleArticlePresenter extends BasePresenter<IArticleView> {
|
|
|
}
|
|
}
|
|
|
};
|
|
};
|
|
|
|
|
|
|
|
|
|
+ mProgressDisposableList.add(disposable);
|
|
|
|
|
+
|
|
|
Observable.create((ObservableOnSubscribe<String>) emitter -> {
|
|
Observable.create((ObservableOnSubscribe<String>) emitter -> {
|
|
|
try {
|
|
try {
|
|
|
Thread.sleep(5000);
|
|
Thread.sleep(5000);
|
|
@@ -81,7 +83,5 @@ public class SimpleArticlePresenter extends BasePresenter<IArticleView> {
|
|
|
.subscribeOn(Schedulers.io())
|
|
.subscribeOn(Schedulers.io())
|
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
.observeOn(AndroidSchedulers.mainThread())
|
|
|
.subscribe(disposable);
|
|
.subscribe(disposable);
|
|
|
-
|
|
|
|
|
- mProgressDisposableList.add(disposable);
|
|
|
|
|
}
|
|
}
|
|
|
}
|
|
}
|