RxExceptionsHandler Handler Rule

RxSchedulersTrampolineRule.kt

class RxSchedulersTrampolineRule : ExternalResource() {
    private var defaultExceptionHandler: Thread.UncaughtExceptionHandler? = null

    override fun before() {
        // Remember current default exception handler and replace it with one that rethrows the exception
        // Rethrowing allows unit test fail in the same place the application would fail.
        defaultExceptionHandler = Thread.getDefaultUncaughtExceptionHandler()
        Thread.setDefaultUncaughtExceptionHandler { _, exc -> throw exc }

        // Turn on Trampoline rule to execute RX call synchronously
        RxAndroidPlugins.setInitMainThreadSchedulerHandler { Schedulers.trampoline() }
        RxJavaPlugins.setIoSchedulerHandler { Schedulers.trampoline() }
    }

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

        Thread.setDefaultUncaughtExceptionHandler(defaultExceptionHandler)
    }
}