public abstract Class DeferredScalarObserver<T, R>

Class Inheritance

extends DeferredScalarDisposable<R>
implements Observer<T>

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.observers.BasicIntQueueDisposable
io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable
io.reactivex.rxjava3.internal.observers.DeferredScalarObserver

All Implemented Interfaces

io.reactivex.rxjava3.core.Observer

Type Parameters

<T>: the input value type
<R>: the output value type

Imports

io.reactivex.rxjava3.core.Observer, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.internal.disposables.DisposableHelper

A fuseable Observer that can generate 0 or 1 resulting value.

Field Summary

Modifier and Type	Field and Description
private static final long	serialVersionUID Hides io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable.serialVersionUID.
protected Disposable	upstream The upstream disposable.

Inherited from io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable:: DISPOSED downstream FUSED_CONSUMED FUSED_EMPTY FUSED_READY TERMINATED value

Constructor Summary

Access	Constructor and Description
public	DeferredScalarObserver(Observer<? super R> the downstream subscriber, not null (not verified) downstream) Creates a DeferredScalarObserver instance and wraps a downstream Observer.

Method Summary

Modifier and Type	Method and Description
public void	dispose() Overrides io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable.dispose. Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
public void	onComplete() Implements io.reactivex.rxjava3.core.Observer.onComplete. Notifies the `Observer` that the `Observable` has finished sending push-based notifications.
public void	onError(Throwable t)
public void	onSubscribe(Disposable d)

Inherited from io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable:: clear complete complete error isDisposed isEmpty poll requestFusion tryDispose

Field Detail

serialVersionUID	back to summary
private static final long serialVersionUID Hides io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable.serialVersionUID.

upstream	back to summary
protected Disposable upstream The upstream disposable.

Constructor Detail

DeferredScalarObserver	back to summary
public DeferredScalarObserver(Observer<? super R> downstream) Creates a DeferredScalarObserver instance and wraps a downstream Observer. Parameters downstream:Observer<? super R> the downstream subscriber, not null (not verified)

DeferredScalarObserver

back to summary

public DeferredScalarObserver(Observer<? super R> downstream)

Creates a DeferredScalarObserver instance and wraps a downstream Observer.

Parameters

downstream:Observer<? super R>: the downstream subscriber, not null (not verified)

Method Detail

dispose	back to summary
public void dispose() Overrides io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable.dispose. Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Doc from io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Overrides io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable.dispose.

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Doc from io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations

@Override

onComplete back to summary

onComplete	back to summary
public void onComplete() Implements io.reactivex.rxjava3.core.Observer.onComplete. Doc from io.reactivex.rxjava3.core.Observer.onComplete. Notifies the `Observer` that the `Observable` has finished sending push-based notifications. The `Observable` will not call this method if it calls `onError`. Annotations @Override

public void onComplete()

Implements io.reactivex.rxjava3.core.Observer.onComplete.

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

Notifies the Observer that the Observable has finished sending push-based notifications.

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

Annotations

@Override

onError	back to summary
public void onError(Throwable t) Annotations @Override

onSubscribe	back to summary
public void onSubscribe(Disposable d) Annotations @Override