Package net.corda.core.observable.internal
See: Description
-
Class Summary Class Description ResilientSubscriber Extends SafeSubscriber to override SafeSubscriber. OnNextFailedException We throw OnNextFailedException to pass the exception back through the preceding Subscriber chain without triggering any SafeSubscriber. OnResilientSubscribe OnResilientSubscribe returns an Observable holding a reference to the source Observable.