docs/net.corda.core.observable.internal

Package-level declarations

Types

class OnNextFailedException(message: String, cause: Throwable)

We throw OnNextFailedException to pass the exception back through the preceding Subscriber chain without triggering any SafeSubscriber.onErrors. Since we are extending an OnErrorNotImplementedException the exception will be re-thrown at Exceptions.throwOrReport.

OnResilientSubscribe

class OnResilientSubscribe<T>(val source: <Error class: unknown class><T>, strictMode: Boolean)

OnResilientSubscribe returns an Observable holding a reference to the source Observable. Upon subscribing to it, when reaching call method, if the subscriber passed in isSafeSubscriber it will unwrap the Observer from the SafeSubscriber, re-wrap it with ResilientSubscriber and then subscribe it to the source Observable.

ResilientSubscriber

@VisibleForTesting

class ResilientSubscriber<T>(actual: <Error class: unknown class><in T>)

Extends SafeSubscriber to override SafeSubscriber.onNext, SafeSubscriber.onError and SafeSubscriber._onError.