ObservableToSingle_firstOrError_hot.kt

@Test
fun `hot observable to single with firstOrError`() {
    val observable = Observable.fromIterable<Int>((1..5).toList())
        .doOnNext { println("Source observable emitting $it") }
        .publish()

    val single = observable.firstOrError()
        .doOnSuccess { println("Single succeeded with value: $it") }

    val testObserver = single.test()
    observable.connect()
    testObserver.await()

    testObserver.apply {
        assertComplete()
        assertValue(1)
    }
}