RxJava 3 3.1.8 · io.reactivex.rxjava3.internal.observers.DeferredScalarDisposable

Field Summary

Modifier and Type	Field and Description
pack-priv static final int	DISPOSED Indicates the Disposable has been disposed.
protected final Observer<? super T>	downstream The target of the events.
pack-priv static final int	FUSED_CONSUMED Indicates this Disposable is in fusion mode and its value has been consumed.
pack-priv static final int	FUSED_EMPTY Indicates this Disposable is in fusion mode and is currently empty.
pack-priv static final int	FUSED_READY Indicates this Disposable is in fusion mode and has a value.
private static final long	serialVersionUID Hides io.reactivex.rxjava3.internal.observers.BasicIntQueueDisposable.serialVersionUID.
pack-priv static final int	TERMINATED Indicates there was a call to complete(T).
protected T	value Hides java.util.concurrent.atomic.AtomicInteger.value. The value stored temporarily when in fusion mode.

Constructor Summary

Access	Constructor and Description
public	DeferredScalarDisposable(Observer<? super T> the Observer to wrap, not null (not verified) downstream) Constructs a DeferredScalarDisposable by wrapping the Observer.

Method Summary

Modifier and Type	Method and Description
public final void	clear() Implements io.reactivex.rxjava3.operators.SimpleQueue.clear. Removes all enqueued items from this queue.
public final void	complete(T the value to signal, not null (not verified) value) Complete the target with a single value or indicate there is a value available in fusion mode.
public final void	complete() Complete the target without any value.
public void	dispose() Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
public final void	error(Throwable the Throwable to signal, not null (not verified) t) Complete the target with an error signal.
public final boolean	isDisposed() Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public final boolean	isEmpty() Implements io.reactivex.rxjava3.operators.SimpleQueue.isEmpty. Returns true if the queue is empty.
public final T	poll() Implements io.reactivex.rxjava3.operators.SimpleQueue.poll. Tries to dequeue a value (non-null) or returns null if the queue is empty.
public final int	requestFusion(int the requested fusion mode, allowed values are `SYNC`, `ASYNC`, `ANY` combined with `BOUNDARY` (e.g., `requestFusion(SYNC \| BOUNDARY)`). mode) Implements io.reactivex.rxjava3.operators.QueueFuseable.requestFusion. Request a fusion mode from the upstream.
public final boolean	Returns: true if the current thread succeeded tryDispose() Try disposing this Disposable and return true if the current thread succeeded.

Inherited from io.reactivex.rxjava3.internal.observers.BasicIntQueueDisposable:: offer offer

Field Detail

DISPOSED	back to summary
pack-priv static final int DISPOSED Indicates the Disposable has been disposed.

downstream	back to summary
protected final Observer<? super T> downstream The target of the events.

FUSED_CONSUMED	back to summary
pack-priv static final int FUSED_CONSUMED Indicates this Disposable is in fusion mode and its value has been consumed.

FUSED_EMPTY	back to summary
pack-priv static final int FUSED_EMPTY Indicates this Disposable is in fusion mode and is currently empty.

FUSED_READY	back to summary
pack-priv static final int FUSED_READY Indicates this Disposable is in fusion mode and has a value.

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

TERMINATED	back to summary
pack-priv static final int TERMINATED Indicates there was a call to complete(T).

value	back to summary
protected T value Hides java.util.concurrent.atomic.AtomicInteger.value. The value stored temporarily when in fusion mode.

value

back to summary

protected T value

Hides java.util.concurrent.atomic.AtomicInteger.value.

The value stored temporarily when in fusion mode.

Constructor Detail

DeferredScalarDisposable	back to summary
public DeferredScalarDisposable(Observer<? super T> downstream) Constructs a DeferredScalarDisposable by wrapping the Observer. Parameters downstream:Observer<? super T> the Observer to wrap, not null (not verified)

DeferredScalarDisposable

back to summary

public DeferredScalarDisposable(Observer<? super T> downstream)

Constructs a DeferredScalarDisposable by wrapping the Observer.

Parameters

downstream:Observer<? super T>: the Observer to wrap, not null (not verified)

Method Detail

clear	back to summary
public final void clear() Implements io.reactivex.rxjava3.operators.SimpleQueue.clear. Doc from io.reactivex.rxjava3.operators.SimpleQueue.clear. Removes all enqueued items from this queue. Annotations @Override

clear

back to summary

public final void clear()

Implements io.reactivex.rxjava3.operators.SimpleQueue.clear.

Doc from io.reactivex.rxjava3.operators.SimpleQueue.clear.

Removes all enqueued items from this queue.

Annotations

@Override

complete	back to summary
public final void complete(T value) Complete the target with a single value or indicate there is a value available in fusion mode. Parameters value:T the value to signal, not null (not verified)

complete

back to summary

public final void complete(T value)

Complete the target with a single value or indicate there is a value available in fusion mode.

Parameters

value:T: the value to signal, not null (not verified)

complete	back to summary
public final void complete() Complete the target without any value.

dispose	back to summary
public void 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()

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

error	back to summary
public final void error(Throwable t) Complete the target with an error signal. Parameters t:Throwable the Throwable to signal, not null (not verified)

error

back to summary

public final void error(Throwable t)

Complete the target with an error signal.

Parameters

t:Throwable: the Throwable to signal, not null (not verified)

isDisposed	back to summary
public final boolean isDisposed() Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed. Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed. Returns true if this resource has been disposed. Returns:boolean true if this resource has been disposed Annotations @Override

isDisposed

back to summary

public final boolean isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

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

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations

@Override

isEmpty back to summary

isEmpty	back to summary
public final boolean isEmpty() Implements io.reactivex.rxjava3.operators.SimpleQueue.isEmpty. Doc from io.reactivex.rxjava3.operators.SimpleQueue.isEmpty. Returns true if the queue is empty. Note however that due to potential fused functions in `poll()` it is possible this method returns false but then poll() returns null because the fused function swallowed the available item(s). Returns:boolean true if the queue is empty Annotations @Override

public final boolean isEmpty()

Implements io.reactivex.rxjava3.operators.SimpleQueue.isEmpty.

Doc from io.reactivex.rxjava3.operators.SimpleQueue.isEmpty.

Returns true if the queue is empty.

Note however that due to potential fused functions in poll() it is possible this method returns false but then poll() returns null because the fused function swallowed the available item(s).

Returns:boolean

true if the queue is empty

Annotations

@Override

poll back to summary

poll	back to summary
public final T poll() Implements io.reactivex.rxjava3.operators.SimpleQueue.poll. Doc from io.reactivex.rxjava3.operators.SimpleQueue.poll. Tries to dequeue a value (non-null) or returns null if the queue is empty. If the producer uses `offer(Object, Object)` and when polling in pairs, if the first poll() returns a non-null item, the second poll() is guaranteed to return a non-null item as well. Returns:T the item or null to indicate an empty queue Annotations @Nullable @Override

public final T poll()

Implements io.reactivex.rxjava3.operators.SimpleQueue.poll.

Doc from io.reactivex.rxjava3.operators.SimpleQueue.poll.

Tries to dequeue a value (non-null) or returns null if the queue is empty.

If the producer uses offer(Object, Object) and when polling in pairs, if the first poll() returns a non-null item, the second poll() is guaranteed to return a non-null item as well.

Returns:T

the item or null to indicate an empty queue

Annotations

@Nullable
@Override

requestFusion back to summary

requestFusion	back to summary
public final int requestFusion(int mode) Implements io.reactivex.rxjava3.operators.QueueFuseable.requestFusion. Doc from io.reactivex.rxjava3.operators.QueueFuseable.requestFusion. Request a fusion mode from the upstream. This should be called before `onSubscribe` returns. Calling this method multiple times or after `onSubscribe` finished is not allowed and may result in undefined behavior. Parameters mode:int the requested fusion mode, allowed values are `SYNC`, `ASYNC`, `ANY` combined with `BOUNDARY` (e.g., `requestFusion(SYNC \| BOUNDARY)`). Returns:int the established fusion mode: `NONE`, `SYNC`, `ASYNC`. Annotations @Override

public final int requestFusion(int mode)

Implements io.reactivex.rxjava3.operators.QueueFuseable.requestFusion.

Doc from io.reactivex.rxjava3.operators.QueueFuseable.requestFusion.

Request a fusion mode from the upstream.

This should be called before onSubscribe returns.

Calling this method multiple times or after onSubscribe finished is not allowed and may result in undefined behavior.

Parameters

mode:int: the requested fusion mode, allowed values are SYNC, ASYNC, ANY combined with BOUNDARY (e.g., requestFusion(SYNC | BOUNDARY)).

Returns:int

the established fusion mode: NONE, SYNC, ASYNC.

Annotations

@Override

tryDispose	back to summary
public final boolean tryDispose() Try disposing this Disposable and return true if the current thread succeeded. Returns:boolean true if the current thread succeeded

tryDispose

back to summary

public final boolean tryDispose()

Try disposing this Disposable and return true if the current thread succeeded.

Returns:boolean: true if the current thread succeeded

public Class DeferredScalarDisposable<T>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail