net.corda.core.observable

Class Observables

net.corda.core.observable.Observables

public class Observables

Constructor Detail

Observables

public Observables()

Method Detail

continueOnError

@NotNull
public static <T> rx.Observable<T> continueOnError(@NotNull
                                                            rx.Observable<T> $this$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.

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

See Also:

Observable.continueOnError, Observable.continueOnError