kotlin - RxKotlin - Single.just() 在订阅 TestSubscriber 时不会发出

Question

我以为这就是它的工作原理，好像我错过了一些东西..

@Test
fun singleCompletes()
{
    val testSubscriber = TestSubscriber<Boolean>()

    Single.just(true)
            .subscribeOn(Schedulers.immediate())
            .subscribe { testSubscriber }

    testSubscriber.assertNoErrors()
    testSubscriber.assertValue(true)
}

java.lang.AssertionError：项目数不匹配。提供：1 实际：0。

Answer 1

我认为您的调用subscribe不正确。

看来你的意思

Single.just(true)
    .subscribeOn(Schedulers.immediate())
    .subscribe(testSubscriber)

这将调用subscribe(Subscriber<? super T> subscriber).

您的代码正在调用subscribe(final Action1<? super T> onSuccess)，这将解释您所看到的。