Подскажите пожалуйста как мне в пуле Schedulers.io совершить две операции, добавить в бд(это в принципе получилось) и сразу прочить данные с бд и закинуть их в список(список используется для адаптера в recycle view). В моей реализации я это делаю в mainThread через onNext, тем самым постоянно стопорю главный поток и из-за этого происходят задержки при прокрутке recycle view. Пытался сделать это через добавление еще одного оператора doOnNext в пуле, но при этом видимо из-за цикла получается какая-то чушь или я что-то недопонял, прощу помощи.
public void newsGetRxEnd(List<News> forAdapter, RecyclerView mRecyclerView, Context context) {
Link link = retrofit.create(Link.class);
Observable<List<News>> observable = link.endNews(db.getMin("news", "idNews"));
observable.subscribeOn(Schedulers.io())
.flatMap(urls -> Observable.from(urls))
.doOnNext(url -> db.addRec(url.getTitle(), url.getId(), url.getSummary(),
String.valueOf(url.getNewsDate())))
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<News>() {
@Override
public void onCompleted() {
newsAdapterRX(forAdapter, mRecyclerView);
Log.d(LOG_TAG,"onCompleted");
}
@Override
public void onError(Throwable e) {
Log.d(LOG_TAG,"onError " + e);
}
@Override
public void onNext(News news) {
Log.d(LOG_TAG,"onNext");
for (int i = forAdapter.size(); i < db.getNewsList().size(); i++) {
forAdapter.add(db.getNewsList().get(i));
Log.d(LOG_TAG,"В новом потоке " + db.getNewsList().get(i).getTitle());
}
}});
}