Class DisposableAutoReleaseObserver<T>
java.lang.Object
java.util.concurrent.atomic.AtomicReference<Disposable>
io.reactivex.rxjava3.internal.observers.AbstractDisposableAutoRelease
io.reactivex.rxjava3.internal.observers.DisposableAutoReleaseObserver<T>
- Type Parameters:
T
- the element type consumed
- All Implemented Interfaces:
Observer<T>
,Disposable
,LambdaConsumerIntrospection
,Serializable
public final class DisposableAutoReleaseObserver<T>
extends AbstractDisposableAutoRelease
implements Observer<T>
Wraps lambda callbacks and when the upstream terminates or this observer gets disposed,
removes itself from a
CompositeDisposable
.
History: 0.18.0 @ RxJavaExtensions
- Since:
- 3.1.0
- See Also:
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final long
Fields inherited from class io.reactivex.rxjava3.internal.observers.AbstractDisposableAutoRelease
composite, onComplete, onError
-
Constructor Summary
ConstructorsConstructorDescriptionDisposableAutoReleaseObserver
(DisposableContainer composite, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) -
Method Summary
Methods inherited from class io.reactivex.rxjava3.internal.observers.AbstractDisposableAutoRelease
dispose, hasCustomOnError, isDisposed, onComplete, onError, onSubscribe, removeSelf
Methods inherited from class java.util.concurrent.atomic.AtomicReference
accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile
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
onComplete, onError, onSubscribe
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
onNext
-
-
Constructor Details
-
DisposableAutoReleaseObserver
-
-
Method Details
-
onNext
Description copied from interface:Observer
Provides theObserver
with a new item to observe.The
Observable
may call this method 0 or more times.The
Observable
will not call this method again after it calls eitherObserver.onComplete()
orObserver.onError(java.lang.Throwable)
.
-