PublishSubject 不适用于 firstOrError()

Question

有人可以解释一下为什么PublishSubject 不能很好地与firstOrError() 合作吗？

我希望 firstOrError 在创建 PublishSubject 时返回 NoSuchElementException 而没有任何值。

为了更好地解释问题，我写了一些测试：

@Test
fun `test one`() {
    // THIS TEST FAILS
    val publishSubject = PublishSubject.create<Boolean>()

    val testSubscriber = publishSubject
        // .toFlowable(BackpressureStrategy.LATEST) // With or without this doesn't make any difference
        .firstOrError()
        .test()

    testSubscriber
        .assertNotComplete()
        .assertError(NoSuchElementException::class.java)
}

@Test
fun `test two`() {
    // THIS TEST PASSES
    val flowable = Flowable.empty<Boolean>()

    val testSubscriber = flowable
        .firstOrError()
        .test()

    testSubscriber
        .assertNotComplete()
        .assertError(NoSuchElementException::class.java)
}

Answer 1

短版：Flowable 不发射任何元素并完成，而PublishSubject 不发射任何元素且未完成。

长版：

您假设PublishSubject.create<Boolean>() 等价于Flowable.empty<Boolean>()。但他们不是。

首先，让我们看看firstOrError() 的真正作用：

返回一个 Single，它只发出此 Observable 发出的第一个项目，如果此 Observable 为空，则发出 NoSuchElementException 信号。

所以你认为Flowable.empty<Boolean>() 有效，因为它是空的。 "empty" 是什么意思？

返回一个不向订阅者发送任何项目并立即调用其 onComplete 方法的 Flowable。

我强调了重要的片段。 Flowable.empty() 调用onComplete 而PublishSubject.create() 只是创建Subject 等待他或订阅者调用onNext()。

所以Flowable.empty() 为空，但PublishSubject.create() 不为空。 它不会调用onComplete。有关更多信息，请参阅PublishSubject docs。

如果你想有空的PublishSubject，只需调用PublishSubject.empty<Boolean>()。