Catch UndeliverableException

RxTest.kt

    @Test
    fun simple() {
        val observable = Observable.create<Int> { emitter ->
            emitter.onNext(1)
            emitter.onError(IOException("Timeout"))
        }
        observable
                .take(1)
                .subscribe({ assertEquals(1, it) }, { assertTrue(it is UndeliverableException) })
    }

    @Test
    fun complicated() {
        val catchException = object : Thread.UncaughtExceptionHandler {
            var caught: Throwable? = null

            override fun uncaughtException(thread: Thread, throwable: Throwable) {
                caught = throwable
            }
        }

        val latch = CountDownLatch(1)
        val observable = Observable.fromCallable {
            println("Doing something")
            latch.await() //Expect InterruptedException
        }
        val subscription = observable
                .subscribeOn(Schedulers.from(Executors.newSingleThreadExecutor({
                    Thread(it)
                            .apply { uncaughtExceptionHandler = catchException }
                })))
                .subscribe {
                    fail()
                }
        Thread.sleep(100) //Slack
        subscription.dispose() //Cause InterruptedException
        Thread.sleep(100) //Slack
        assertTrue(catchException.caught is UndeliverableException)
    }