ObservableToSingle_firstOrError_error2.kt

@Throws(UndeliverableException::class)
@Test
fun `observable that throws error after emitting an item to single with firstOrError`() {
    RxJavaPlugins.setErrorHandler { System.err.println("An unhandled exception was caught: $it") }

    val observable = Observable.create<Int> { emitter ->
        emitter.onNext(1)
        emitter.onNext(2)
        emitter.onError(RuntimeException("Exception while emitting Ints"))
    }

    assertObservableToSingle(observable, { firstOrError()}) {
        assertComplete()
        assertValue(1)
    }
}