Class DeferredScalarSubscriber<T,R>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

io.reactivex.rxjava3.internal.subscriptions.BasicIntQueueSubscription<R>

io.reactivex.rxjava3.internal.subscriptions.DeferredScalarSubscription<R>

io.reactivex.rxjava3.internal.subscribers.DeferredScalarSubscriber<T,R>

Type Parameters:

T - the input value type

R - the output value type

All Implemented Interfaces:

FlowableSubscriber<T>, QueueFuseable<R>, QueueSubscription<R>, SimpleQueue<R>, Serializable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

Direct Known Subclasses:

ParallelCollect.ParallelCollectSubscriber, ParallelReduce.ParallelReduceSubscriber

public abstract class DeferredScalarSubscriber<T,R>
extends DeferredScalarSubscription<R>
implements FlowableSubscriber<T>

A subscriber, extending a DeferredScalarSubscription, that is unbounded-in and can generate 0 or 1 resulting value.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	hasValue	Can indicate if there was at least on onNext call.
private static final long	serialVersionUID
protected org.reactivestreams.Subscription	upstream	The upstream subscription.

Fields inherited from class DeferredScalarSubscription

downstream, value

Fields inherited from interface QueueFuseable

ANY, ASYNC, BOUNDARY, NONE, SYNC

Constructor Summary

Constructors

Constructor	Description
DeferredScalarSubscriber(org.reactivestreams.Subscriber<? super R> downstream)	Creates a DeferredScalarSubscriber instance and wraps a downstream Subscriber.

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	onComplete()
void	onError(Throwable t)
void	onSubscribe(org.reactivestreams.Subscription s)	Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long).

Methods inherited from class DeferredScalarSubscription

clear, complete, isCancelled, isEmpty, poll, request, requestFusion, tryCancel

Methods inherited from class BasicIntQueueSubscription

offer, offer

Methods inherited from class AtomicInteger

accumulateAndGet, addAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, decrementAndGet, doubleValue, floatValue, get, getAcquire, getAndAccumulate, getAndAdd, getAndDecrement, getAndIncrement, getAndSet, getAndUpdate, getOpaque, getPlain, incrementAndGet, intValue, lazySet, longValue, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile

Methods inherited from class Number

byteValue, shortValue

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.reactivestreams.Subscriber

onNext

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

upstream

protected org.reactivestreams.Subscription upstream

The upstream subscription.

hasValue

protected boolean hasValue

Can indicate if there was at least on onNext call.

Constructor Details

DeferredScalarSubscriber

public DeferredScalarSubscriber(org.reactivestreams.Subscriber<? super R> downstream)

Creates a DeferredScalarSubscriber instance and wraps a downstream Subscriber.

Parameters:

downstream - the downstream subscriber, not null (not verified)

Method Details

onSubscribe

public void onSubscribe(org.reactivestreams.Subscription s)

Description copied from interface: FlowableSubscriber

Implementors of this method should make sure everything that needs to be visible in Subscriber.onNext(Object) is established before calling Subscription.request(long). In practice this means no initialization should happen after the request() call and additional behavior is thread safe in respect to onNext.

Specified by:

onSubscribe in interface FlowableSubscriber<T>

Specified by:

onSubscribe in interface org.reactivestreams.Subscriber<T>

onError

public void onError(Throwable t)

Specified by:

onError in interface org.reactivestreams.Subscriber<T>

onComplete

public void onComplete()

Specified by:

onComplete in interface org.reactivestreams.Subscriber<T>

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

Overrides:

cancel in class DeferredScalarSubscription<R>