Top Description Fields Constructors Methods
io.reactivex.rxjava3.internal.observers

public final Class DisposableAutoReleaseObserver<T>

extends AbstractDisposableAutoRelease
implements Observer<T>
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.core.Observer
Type Parameters
<T>
the element type consumed
Imports
io.reactivex.rxjava3.core.Observer, io.reactivex.rxjava3.disposables.DisposableContainer, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.*, io.reactivex.rxjava3.internal.disposables.DisposableHelper
Wraps lambda callbacks and when the upstream terminates or this observer gets disposed, removes itself from a io.reactivex.rxjava3.disposables.CompositeDisposable.

History: 0.18.0 @ RxJavaExtensions

Since
3.1.0

Field Summary

Modifier and TypeField and Description
pack-priv final Consumer<? super T>
onNext

private static final long
serialVersionUID

Hides io.reactivex.rxjava3.internal.observers.AbstractDisposableAutoRelease.serialVersionUID.

Inherited from io.reactivex.rxjava3.internal.observers.AbstractDisposableAutoRelease:
compositeonCompleteonError

Constructor Summary

AccessConstructor and Description
public
DisposableAutoReleaseObserver(DisposableContainer composite, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)

Method Summary

Modifier and TypeMethod and Description
public void
onNext(T
the item emitted by the Observable
t)

Implements io.reactivex.rxjava3.core.Observer.onNext.

Provides the Observer with a new item to observe.
Inherited from io.reactivex.rxjava3.internal.observers.AbstractDisposableAutoRelease:
disposehasCustomOnErrorisDisposedonCompleteonErroronSubscriberemoveSelf

Field Detail

onNextback to summary
pack-priv final Consumer<? super T> onNext
serialVersionUIDback to summary
private static final long serialVersionUID

Hides io.reactivex.rxjava3.internal.observers.AbstractDisposableAutoRelease.serialVersionUID.

Constructor Detail

DisposableAutoReleaseObserverback to summary
public DisposableAutoReleaseObserver(DisposableContainer composite, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)

Method Detail

onNextback to summary
public void onNext(T t)

Implements io.reactivex.rxjava3.core.Observer.onNext.

Doc from io.reactivex.rxjava3.core.Observer.onNext.

Provides the Observer 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 either onComplete or onError.

Parameters
t:T

the item emitted by the Observable

Annotations
@Override