Package io.github.resilience4j.rxjava3

Class AbstractObserver<T>

java.lang.Object

io.github.resilience4j.rxjava3.AbstractDisposable

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

All Implemented Interfaces:

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

Direct Known Subclasses:

ObserverBulkhead.BulkheadObserver, ObserverCircuitBreaker.CircuitBreakerObserver, ObserverRateLimiter.RateLimiterObserver

public abstract class AbstractObserver<T>
extends AbstractDisposable
implements io.reactivex.rxjava3.core.Observer<T>

Field Summary

Fields

Modifier and Type	Field	Description
private final io.reactivex.rxjava3.core.Observer<? super T>	downstreamObserver
protected final AtomicBoolean	eventWasEmitted

Constructor Summary

Constructors

Constructor	Description
AbstractObserver(io.reactivex.rxjava3.core.Observer<? super T> downstreamObserver)

Method Summary

Modifier and Type	Method	Description
protected abstract void	hookOnComplete()
protected abstract void	hookOnError(Throwable e)
protected void	hookOnNext(T value)
protected void	hookOnSubscribe()
void	onComplete()
void	onError(Throwable e)
void	onNext(T item)

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.Observer

onSubscribe

Field Details

eventWasEmitted

protected final AtomicBoolean eventWasEmitted

downstreamObserver

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

Constructor Details

AbstractObserver

public AbstractObserver(io.reactivex.rxjava3.core.Observer<? super T> downstreamObserver)

Method Details

hookOnSubscribe

protected void hookOnSubscribe()

Specified by:

hookOnSubscribe in class AbstractDisposable

onNext

public void onNext(T item)

Specified by:

onNext in interface io.reactivex.rxjava3.core.Observer<T>

hookOnNext

protected void hookOnNext(T value)

onError

public void onError(Throwable e)

Specified by:

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

hookOnError

protected abstract void hookOnError(Throwable e)

onComplete

public void onComplete()

Specified by:

onComplete in interface io.reactivex.rxjava3.core.Observer<T>

hookOnComplete

protected abstract void hookOnComplete()