RxJava2 中的意外返回值错误

Question

需要帮助来解决 RxJava 中的返回值问题。所以，这是我到目前为止所做的：

private Observable<Boolean> updatedMenuItems() {
    return Observable.fromIterable(getAliases())
        .doOnNext(alias -> {
            return ApiRepository.getMenuItemBlocks(alias)
                    .subscribeOn(Schedulers.io())
                    .flatMapIterable(list -> list)
                    .map(item -> item.getFileTimeStamp() == null ? "" : item.getFileTimeStamp().toString())
                    .toList()
                    .doOnSuccess(apiContents -> {
                        return Observable.fromCallable(DataStoreRepository::loadMenuItemsBlock)
                                .subscribeOn(Schedulers.io())
                                .flatMapIterable(list -> list)
                                .map(item -> item.fileTimeStamp == null ? "" : item.fileTimeStamp.toString())
                                .toList()
                                .map(dbContents -> {
                                    return DBUtil.isContentEqual(dbContents, apiContents);
                                });
                    });

        });
}

我需要从此方法返回Observable<Boolean> 数据类型，但在.doOnSuccess(...); 块内我收到有关返回值的错误。请你帮我解决这个问题。谢谢！

Answer 1

doOnNext、doOnSuccess、doOnError、doOnCompleted

这些被称为副作用运算符，无论如何它们不会真正影响链，它们可能被用作 ex 的日志记录机制。

您正在寻找的可能是 flatMap，来自文档：

FlatMap：将 Observable 发射的项目转换为 Observable，然后将这些项目的发射扁平化为单个 Observable。