android - RxJava 在单个订阅者中观察多个观察者

Question

代码

Author author = baseRealm.where(Author.class).equalTo("id", mId).findFirst();

public boolean checkGlobalSyncStatus(Author author, List<Books> mBooks) {

    final boolean[] isJobSynchronized = {false};

    Observable.fromIterable(mBooks)
            .filter(Books::isChanged)
            .doOnNext(book -> isJobSynchronized[0] = true)
            .just(author)
            .flatMapIterable(Author::getAllBooks)
            .filter(MyBook::isChanged)
            .doOnNext(mBook -> isJobSynchronized[0] = true)
            .just(author)
            .flatMapIterable(Author::getAllWriters)
            .filter(Writers::isChanged)
            .doOnNext(jobPage -> isJobSynchronized[0] = true)
            .subscribe();

    return isJobSynchronized[0];
}

问题

fromIterable(mBooks) 从 static-reference Observable BUT just(author) 调用 从 instance-reference 调用。

我只想在单个查询中完成此操作。我可以为每个对象创建不同的可观察对象并执行所需的操作，但这会很长。

为什么？

通过这样做，SonarQube 给我不成功的检查并迫使我删除instance-reference。

任何替代方案将不胜感激。

---

Answer 1

当 just() 确实是可观察的时，您正试图将其用作运算符。看起来您的 Intent 是使用传入的 author 进行一系列查询，然后检查与作者关联的任何书籍是否已“更改”。

此外，您正在尝试返回一个 bool 值，该值在返回发生时可能尚未设置。如果您想要该值，您可能需要阻塞并等待观察者链完成。更有可能的是，您希望观察者链在任何书发生变化时结束。

此外，将标志设置为 true 的一系列步骤归结为第一次将标志设置为 true。

代替just()，使用map()将原作者重新绑定(bind)到观察者链中。使用 toBlocking() 运算符使进程同步。

Observable.fromIterable(mBooks)
        .filter(Books::isChanged)
        .toBlocking()
        .subscribe( ignored -> isJobSynchronized[0] = true );

return isJobSynchronized[0];

由于(大概)异步查询不再需要计算值，删除 RxJava:

return mBooks.stream()
         .filter(Books::isChanged)
         .anyMatch();