RxJava 3 3.1.8 · io.reactivex.rxjava3.internal.operators.single.SingleOnErrorComplete

Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.

Field Summary

Modifier and Type	Field and Description
pack-priv final Predicate<? super Throwable>	predicate
pack-priv final Single<T>	source

Constructor Summary

Access	Constructor and Description
public	SingleOnErrorComplete(Single<T> source, Predicate<? super Throwable> predicate)

Method Summary

Modifier and Type	Method and Description
protected void	subscribeActual(MaybeObserver<? super T> observer)

Inherited from io.reactivex.rxjava3.core.Maybe:: amb ambArray ambWith blockingGet blockingGet blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe blockingSubscribe cache cast compose concat concat concat concat concat concat concatArray concatArrayDelayError concatArrayEager concatArrayEagerDelayError concatDelayError concatDelayError concatDelayError concatEager concatEager concatEager concatEager concatEagerDelayError concatEagerDelayError concatEagerDelayError concatEagerDelayError concatMap concatMapCompletable concatMapSingle concatWith contains count create defaultIfEmpty defer delay delay delay delay delay delaySubscription delaySubscription delaySubscription dematerialize doAfterSuccess doAfterTerminate doFinally doOnComplete doOnDispose doOnError doOnEvent doOnLifecycle doOnSubscribe doOnSuccess doOnTerminate empty error error filter flatMap flatMap flatMap flatMapCompletable flatMapObservable flatMapPublisher flatMapSingle flattenAsFlowable flattenAsObservable flattenStreamAsFlowable flattenStreamAsObservable fromAction fromCallable fromCompletable fromCompletionStage fromFuture fromFuture fromObservable fromOptional fromPublisher fromRunnable fromSingle fromSupplier hide ignoreElement isEmpty just lift map mapOptional materialize merge merge merge merge merge merge merge mergeArray mergeArrayDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeDelayError mergeWith never observeOn ofType onErrorComplete onErrorComplete onErrorResumeNext onErrorResumeWith onErrorReturn onErrorReturnItem onTerminateDetach repeat repeat repeatUntil repeatWhen retry retry retry retry retry retryUntil retryWhen safeSubscribe sequenceEqual sequenceEqual startWith startWith startWith startWith startWith subscribe subscribe subscribe subscribe subscribe subscribe subscribeActual subscribeOn subscribeWith switchIfEmpty switchIfEmpty switchOnNext switchOnNextDelayError takeUntil takeUntil test test timeInterval timeInterval timeInterval timeInterval timeout timeout timeout timeout timeout timeout timeout timeout timer timer timestamp timestamp timestamp timestamp to toCompletionStage toCompletionStage toFlowable toFuture toObservable toSingle unsafeCreate unsubscribeOn using using wrap zip zip zip zip zip zip zip zip zip zipArray zipWith

Field Detail

predicate	back to summary
pack-priv final Predicate<? super Throwable> predicate

source	back to summary
pack-priv final Single<T> source

Constructor Detail

SingleOnErrorComplete	back to summary
public SingleOnErrorComplete(Single<T> source, Predicate<? super Throwable> predicate)

Method Detail

subscribeActual	back to summary
protected void subscribeActual(MaybeObserver<? super T> observer) Annotations @Override

public final Class SingleOnErrorComplete<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail