Android rxJava-Null对象包装在观察

Question

我有一个这样简单的用例：在远程源代码中查找一本书，如果它不存在，就创建它。这就是我使用rxJava1的方法：

public void handleBook(int id) {
    getBookById(id) 
        .flatMap(new Func1<Book, Observable<Book>> {
            @Override
            public Observable<Book> call(Book book) {
                if(book != null) // it exists
                ...
                else // it's null - it doesn't exist ...
            }
        }
}


public Observable<Book> getBookById(int id) {
    Book book = remoteSource.book(id)
    return Observable.just(book)
}

在这种情况下，如果对象book为null，则Observable.just调用抛出异常。它显式地检查空值。回到rxJava 1，我可以将一个null作为值传递给Observable.just（或其他附件），然后在映射或平面映射运算符中，我会检查我得到的值是否为null（意味着结果不存在）或否（意味着我得到了一些结果）。

由于这个限制，我似乎不能再做这个检查了。我试着让你看得到。如果book对象为空，则整个线程将完成，并在返回值可见时结束。空（）。

如果我需要的东西在那里，我如何检查执行的rx链，然后分支执行链？

Answer 1

而不是使用Observable

注意：现在我没有IDE，所以代码可能会有一些编译器失败。我想你会很容易修好的

public Single<Book> getBookById(int id) {
    return Single.create((e) => {
        Book book = remoteSource.book(id)
        if (book != null)
            e.emit(book);
        else
            e.fail();
    }
}

public void handleBook(int id) {
    getBookById(id) 
        .onErrorResume(e => createBook(...))
        ...
}

就像前面说的，我不确定确切的代码，但你可以把它当作伪代码来读