Привет всем. вопрос по rxjava2, есть список id, по ним я обращаюсь к базе данной в map и изменю его и в конце получаю список,
но проблема в том что иногда по обращение по бд возвращает null, получаю ошибку onError, Как сделать что бы если один вернулся null,
пусть дальше список формировался и вернул
Observable.just(listId)
.flatMap((Function<ArrayList<String>, ObservableSource<?>>)
Observable::just)
.map(t -> db.getUser(
t.id))
.toList()
.subscribeOn(
Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new SingleObserver<List<String>>() {
@Override public void onSubscribe(Disposable d) { }
@Override public void onSuccess(List<String> strings) {
Log.e("my", "list " + strings);
}
@Override public void onError(Throwable e) {
Log.e("my", "Throwable " + e.getMessage());
}
});