SafeMergeArrayTest.kt

@Nested
@DisplayName("When the first stream throws an error")
inner class FirstStreamError {
    
    private val completable1 = Completable.error(
        Throwable("error 1")
    ).subscribeOn(Schedulers.io())

    @Nested
    @DisplayName("When the second stream throws an error simultaneously")
    inner class SecondStreamError {
        
        private val completable2 = Completable.error(
            Throwable("error 2")
        ).subscribeOn(Schedulers.io())

        @Test
        fun `then the merged stream does not crash`() {
            // TODO
        }
    }
}