corda / net.corda.core.observable / continueOnError

continueOnError

fun <T> <ERROR CLASS><T>.continueOnError(): <ERROR CLASS><T>

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.

Observable.continueOnError should be called before every subscribe to have the aforementioned effect.