onNext() 永远不会在 PublishSubject 上被调用

Question

我正在尝试构建一个演示器，它在某个时间段内计算一些事件，仅在第一次加载时显示加载，并在完成后更新用户界面。因为可以通过多种方式（例如用户首选项）更新事件，所以我需要能够告诉演示者事件已更新并且必须再次刷新它们。这是我现在拥有的：

                      subject
                            .map<List<UpcomingRowViewModel>> {
                                provider.calculateEventsBetween(TimePeriod.aYearFrom(firstDay))
                            }
                            .doOnSubscribe {
                                view.showLoading()
                            }
                            .observeOn(resultScheduler)
                            .subscribeOn(workScheduler)
                            .subscribe { upcomingRowViewModels ->
                                view.display(upcomingRowViewModels)
                            }
                      subject.onNext(TRIGGER)

主题是 Int 的 PublishSubject。我在订阅后立即执行onNext()，因为我希望数据在订阅后立即刷新。

上面的代码在我的单元测试中产生了奇迹，而且只有当我在带有调试器的设备上运行它时。如果我只是运行它（没有任何调试器），它会到达view.showLoading() 部分，但永远不会到达provider.calculateEventsBetween(TimePeriod.aYearFrom(firstDay)，因此 UI 会“卡住”加载。

有什么想法吗？

Answer 1

您没有看到调用的消费者的可能原因是.subscribeOn(workScheduler)。通过将其应用于Subject，它本身没有实际用途，因为订阅Subject 时没有订阅副作用，您延迟订阅Subject 刚好足以让onNext 通话获胜'此时找不到任何观察者。

你可能想要的是这样的：

subject
    .observeOn(resultScheduler)             // <--------------- (1)
    .doOnNext {
        view.showLoading()
    }
    .observeOn(workScheduler)               // <--------------- (2)
    .map<List<UpcomingRowViewModel>> {
        provider.calculateEventsBetween(
            TimePeriod.aYearFrom(firstDay))
    }
    .observeOn(resultScheduler)             // <--------------- (3)
    .subscribe { upcomingRowViewModels ->
        view.display(upcomingRowViewModels)
    }
subject.onNext(TRIGGER)

与执行一次的doOnSubscribe不同，(1) 确保当有工作要做时，主体的 onNext 发射将触发主线程上的加载指示器（假设 resultScheduler 在非测试中为 AndroidSchedulers.mainThread )。然后你想从主线程执行映射，因此 (2) 将项目移动到后台线程。映射完成后，生成的项目会在 (3) 处再次移动到主线程，您的视图可以在其中显示它。