SafeMergeArrayTest.kt

@Test
fun `then the merged stream does not crash`() {
    val waiter = Waiter()

    RxJavaPlugins.setErrorHandler {
        // Fail the test if we receive an exception in the error handler
        waiter.fail("Error handler received an exception: $it")
    }

    Completable.mergeArray(completable1, completable2).test().await()

    Timer().schedule(10) {
        // Pass the test after 10ms if we don't receive an exception
        waiter.resume()
    }

    // Await for waiter.resume() or waiter.fail()
    waiter.await()
}