我以为这是工作原理,好像我丢失了一些东西。

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

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

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

最佳答案

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

看来你是说

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

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

您的代码正在调用subscribe(final Action1<? super T> onSuccess),它将解释您看到的内容。

关于kotlin - RxKotlin-订阅TestSubscriber时不发出Single.just(),我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/41987704/

10-10 16:29