У меня есть метод для примера, мне нужно во время получения запроса вывести progressDialog
, в onCompleted()
- dismiss
в onNext
show
, но по итогу на экран progressDialog
не выводится. В чем может быть причина, скорее всего я чего-то недопонимаю?
public void newsGetRxEnd(RecyclerView mRecyclerView, Context context) {
progressDialog = new ProgressDialog(context, R.style.MyTheme);
progressDialog.setCancelable(false);
progressDialog.setProgressStyle(android.R.style.Widget_ProgressBar_Small);
Link link = retrofit.create(Link.class);
Observable<List<News>> observable = link.endNews(db.getMin("news", "idNews"));
observable.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<List<News>>() {
@Override
public void onCompleted() {
Log.d(LOG_TAG, "onCompleted");
progressDialog.dismiss();
}
@Override
public void onError(Throwable e) {
Log.d(LOG_TAG, "onError " + e);
}
@Override
public void onNext(List<News> newses) {
Log.d(LOG_TAG, "onNext " + newses.size());
for (int i = 0; i < newses.size(); i++) {
db.addRec(newses.get(i).getTitle(), newses.get(i).getId(), newses.get(i).getSummary(),
String.valueOf(newses.get(i).getNewsDate()));
Log.d(LOG_TAG, "db.getNewsList().size(): " + db.getNewsList().size());
}
mRecyclerView.getAdapter().notifyDataSetChanged();
progressDialog.show();
}
});
}