RxJava 2 переопределяет планировщик ввода-вывода в модульном тесте

Я предлагаю вам использовать другой подход и добавить уровень абстракции к вашим планировщикам. У этого парня есть хорошая статья об этом.

В Котлине это выглядело бы примерно так

interface SchedulerProvider {
    fun ui(): Scheduler
    fun computation(): Scheduler
    fun trampoline(): Scheduler
    fun newThread(): Scheduler
    fun io(): Scheduler 
}

И затем вы переопределяете это своей собственной реализацией SchedulerProvider:

class AppSchedulerProvider : SchedulerProvider {
    override fun ui(): Scheduler {
        return AndroidSchedulers.mainThread()
    }

    override fun computation(): Scheduler {
        return Schedulers.computation()
    }

    override fun trampoline(): Scheduler {
        return Schedulers.trampoline()
    }

    override fun newThread(): Scheduler {
        return Schedulers.newThread()
    }

    override fun io(): Scheduler {
        return Schedulers.io()
    }
}

И один для тестовых классов:

class TestSchedulerProvider : SchedulerProvider {
    override fun ui(): Scheduler {
        return Schedulers.trampoline()
    }

    override fun computation(): Scheduler {
        return Schedulers.trampoline()
    }

    override fun trampoline(): Scheduler {
        return Schedulers.trampoline()
    }

    override fun newThread(): Scheduler {
        return Schedulers.trampoline()
    }

    override fun io(): Scheduler {
        return Schedulers.trampoline()
    }
}

Ваш код будет выглядеть так, когда вы вызываете RxJava:

mCompositeDisposable.add(mDataManager.getQuote()
        .subscribeOn(mSchedulerProvider.io())
        .observeOn(mSchedulerProvider.ui())
        .subscribe(Consumer<Quote> {
...

И вы просто переопределите свою реализацию SchedulerProvider в зависимости от того, где вы ее тестируете. Вот пример проекта для справки, я связываю тестовый файл, который будет использовать тестируемую версию SchedulerProvider: https://github.com/Obaied/DingerQuotes/blob/master/app/src/test/java/com/obaied/dingerquotes/QuotePresenterTest.kt#L31

Догадаться! Это было связано с тем, что в этом коде:

validate(data)
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .flatMap { ... }

validate(data) возвращал Observable, который выдавал следующее: emitter.onNext(null). Поскольку RxJava 2 больше не принимает значения null, flatMap не вызывался. Я изменил validate, чтобы вернуть Completable, и обновил переопределение планировщика следующим образом:

RxJavaPlugins.setIoSchedulerHandler { Schedulers.trampoline() }

Теперь испытания пройдены!

Это точный синтаксис, который работал для меня:

RxJavaPlugins.setIoSchedulerHandler(scheduler -> Schedulers.trampoline())

В качестве альтернативы предлагаемым решениям это некоторое время отлично работало в моих проектах. Вы можете использовать его в своих тестовых классах следующим образом:

@get:Rule
val immediateSchedulersRule = ImmediateSchedulersRule()

А класс выглядит так:

class ImmediateSchedulersRule : ExternalResource() {

    val immediateScheduler: Scheduler = object : Scheduler() {

        override fun createWorker() = ExecutorScheduler.ExecutorWorker(Executor { it.run() })

        // This prevents errors when scheduling a delay
        override fun scheduleDirect(run: Runnable, delay: Long, unit: TimeUnit): Disposable {
            return super.scheduleDirect(run, 0, unit)
        }

    }

    override fun before() {
        RxJavaPlugins.setIoSchedulerHandler { immediateScheduler }
        RxJavaPlugins.setComputationSchedulerHandler { immediateScheduler }
        RxJavaPlugins.setNewThreadSchedulerHandler { immediateScheduler }

        RxAndroidPlugins.setInitMainThreadSchedulerHandler { immediateScheduler }
        RxAndroidPlugins.setMainThreadSchedulerHandler { immediateScheduler }
    }

    override fun after() {
        RxJavaPlugins.reset()
    }

}

Вы можете найти способ перехода с TestRule на ExternalResource здесь и получить дополнительную информацию о тестировании. RxJava 2 здесь.