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

public final Class ResumeSingleObserver<T>

extends Object
implements SingleObserver<T>
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.core.SingleObserver
Type Parameters
<T>
the value type
Imports
java.util.concurrent.atomic.AtomicReference, io.reactivex.rxjava3.core.SingleObserver, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.internal.disposables.DisposableHelper

A SingleObserver implementation used for subscribing to the actual SingleSource and replace the current Disposable in a parent AtomicReference.

Field Summary

Modifier and TypeField and Description
pack-priv final SingleObserver<? super T>
pack-priv final AtomicReference<Disposable>

Constructor Summary

AccessConstructor and Description
public

Method Summary

Modifier and TypeMethod and Description
public void
public void
public void
onSuccess(T
the item emitted by the Single
value
)

Implements io.reactivex.rxjava3.core.SingleObserver.onSuccess.

Notifies the SingleObserver with a single item and that the Single has finished sending push-based notifications.
Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

downstreamback to summary
pack-priv final SingleObserver<? super T> downstream
parentback to summary
pack-priv final AtomicReference<Disposable> parent

Constructor Detail

ResumeSingleObserverback to summary
public ResumeSingleObserver(AtomicReference<Disposable> parent, SingleObserver<? super T> downstream)

Method Detail

onErrorback to summary
public void onError(Throwable e)
Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Disposable d)
Annotations
@Override
onSuccessback to summary
public void onSuccess(T value)

Implements io.reactivex.rxjava3.core.SingleObserver.onSuccess.

Doc from io.reactivex.rxjava3.core.SingleObserver.onSuccess.

Notifies the SingleObserver with a single item and that the Single has finished sending push-based notifications.

The Single will not call this method if it calls onError.

Parameters
value:T

the item emitted by the Single

Annotations
@Override