RxKotlin - Single.just() не генерируется при подписке на TestSubscriber

Я думал, что это так работает, кажется, я что-то упускаю..

@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.


kotlin rx-kotlin
person Zackline    schedule 01.02.2017    source источник

Ответы (1)


arrow_upward
3
arrow_downward

Я думаю, что ваш вызов subscribe неверен.

Кажется, вы имели в виду

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

Что вызовет функцию subscribe(Subscriber<? super T> subscriber).

Ваш код вызывает subscribe(final Action1<? super T> onSuccess), что объясняет то, что вы видите.

person Edwin Dalorzo    schedule 01.02.2017