Ребята, подскажите почему flatMap не вызывается. public Observable<Meta> readMeta() {

Question

Ребята, подскажите почему flatMap не вызывается. public Observable<Meta> readMeta() {

return Observable.fromCallable(() -> realm.where(Meta.class).findFirst())
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}

storageService.readMeta()
.flatMap(meta -> meta == null ? Observable.empty()
: storageService.readPosts(0, meta.getPostsCount()))
.subscribe((posts) -> {
if (posts.size() == 0) {
getView().showDownloadInvitation();
} else {
getView().showPosts(posts);
//TODO: Restore scroll state
}
}, (error) -> getView().showErrorMessage(error.getMessage()),
() -> loadPostsSubscription = null);

#android #mobile #programming #russian

0

19.04.2017

1 ответов

15 просмотров

Alexey Kalyaganov · Answer 1

Alexey Kalyaganov Автор вопроса

Потому что при чтении меты валится эксепшн сразу

0

19.04.2017

169 похожих чатов

Ребята, подскажите почему flatMap не вызывается. public Observable<Meta> readMeta() {

1 ответов

Похожие вопросы