corda / net.corda.core.observable / rx.Observable

Extensions for rx.Observable

continueOnError

Observable.continueOnError is used to return an Observable, through which we can subscribe non unsubscribing rx.Observers to the source Observable. Namely, it makes the rx.Observers resilient to exceptions coming out of rx.Observer.onNext.

fun <T> Observable<T>.continueOnError(): Observable<T>