Package io.github.resilience4j.rxjava3

Class AbstractSingleObserver<T>

java.lang.Object

io.github.resilience4j.rxjava3.AbstractDisposable

io.github.resilience4j.rxjava3.AbstractSingleObserver<T>

All Implemented Interfaces:

io.reactivex.rxjava3.core.SingleObserver<T>, io.reactivex.rxjava3.disposables.Disposable

Direct Known Subclasses:

SingleBulkhead.BulkheadSingleObserver, SingleCircuitBreaker.CircuitBreakerSingleObserver, SingleRateLimiter.RateLimiterSingleObserver

public abstract class AbstractSingleObserver<T>
extends AbstractDisposable
implements io.reactivex.rxjava3.core.SingleObserver<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final io.reactivex.rxjava3.core.SingleObserver<? super T>	downstreamObserver

Constructor Summary

Constructors

Constructor	Description
AbstractSingleObserver(io.reactivex.rxjava3.core.SingleObserver<? super T> downstreamObserver)

Method Summary

Modifier and Type	Method	Description
protected abstract void	hookOnError(Throwable e)
protected void	hookOnSubscribe()
protected abstract void	hookOnSuccess(T value)
void	onError(Throwable e)
void	onSuccess(T value)

Methods inherited from class io.github.resilience4j.rxjava3.AbstractDisposable

dispose, hookOnCancel, isDisposed, onSubscribe, toString, whenNotCompleted, whenNotDisposed

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface io.reactivex.rxjava3.core.SingleObserver

onSubscribe

Field Details

downstreamObserver

private final io.reactivex.rxjava3.core.SingleObserver<? super T> downstreamObserver

Constructor Details

AbstractSingleObserver

public AbstractSingleObserver(io.reactivex.rxjava3.core.SingleObserver<? super T> downstreamObserver)

Method Details

hookOnSubscribe

protected void hookOnSubscribe()

Specified by:

hookOnSubscribe in class AbstractDisposable

onError

public void onError(Throwable e)

Specified by:

onError in interface io.reactivex.rxjava3.core.SingleObserver<T>

hookOnError

protected abstract void hookOnError(Throwable e)

onSuccess

public void onSuccess(T value)

Specified by:

onSuccess in interface io.reactivex.rxjava3.core.SingleObserver<T>

hookOnSuccess

protected abstract void hookOnSuccess(T value)