Top Description Fields Constructors Methods
io.reactivex.rxjava3.internal.operators.mixed

public abstract Class ConcatMapXMainSubscriber<T>

extends AtomicInteger
implements FlowableSubscriber<T>
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.core.FlowableSubscriber, org.reactivestreams.Subscriber
Known Direct Subclasses
io.reactivex.rxjava3.internal.operators.mixed.FlowableConcatMapCompletable.ConcatMapCompletableObserver, io.reactivex.rxjava3.internal.operators.mixed.FlowableConcatMapMaybe.ConcatMapMaybeSubscriber, io.reactivex.rxjava3.internal.operators.mixed.FlowableConcatMapSingle.ConcatMapSingleSubscriber
Type Parameters
<T>
the upstream value type
Imports
java.util.concurrent.atomic.AtomicInteger, org.reactivestreams.Subscription, io.reactivex.rxjava3.core.FlowableSubscriber, io.reactivex.rxjava3.exceptions.*, io.reactivex.rxjava3.internal.subscriptions.SubscriptionHelper, io.reactivex.rxjava3.internal.util.*, io.reactivex.rxjava3.operators.QueueFuseable, .QueueSubscription, .SimpleQueue, .SpscArrayQueue
Base class for implementing concatMapX main subscribers.
Since
3.0.10

Field Summary

Modifier and TypeField and Description
pack-priv volatile boolean
cancelled

pack-priv volatile boolean
done

pack-priv final ErrorMode
errorMode

pack-priv final AtomicThrowable
errors

pack-priv final int
prefetch

pack-priv SimpleQueue<T>
queue

private static final long
serialVersionUID

Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

pack-priv boolean
syncFused

pack-priv Subscription
upstream

Constructor Summary

AccessConstructor and Description
public
ConcatMapXMainSubscriber(int prefetch, ErrorMode errorMode)

Method Summary

Modifier and TypeMethod and Description
pack-priv void
clearValue()

Override this to clear values when the downstream disposes.

pack-priv abstract void
disposeInner()

Typically, this should be inner.dispose().

pack-priv abstract void
drain()

Implement the serialized inner subscribing and value emission here.

public final void
onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Successful terminal state.
public final void
onError(Throwable
the throwable signaled
t)

Implements org.reactivestreams.Subscriber.onError.

Failed terminal state.
public final void
onNext(T
the element signaled
t)

Implements org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).
public final void
onSubscribe(Subscription
the Subscription that allows requesting data via Subscription#request(long)
s)

Implements org.reactivestreams.Subscriber.onSubscribe.

Invoked after calling Publisher#subscribe(Subscriber).
pack-priv abstract void
onSubscribeDownstream()

Typically, this should be downstream.onSubscribe(this);.

pack-priv final void
stop()

Inherited from java.util.concurrent.atomic.AtomicInteger:
accumulateAndGetaddAndGetcompareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetdecrementAndGetdoubleValuefloatValuegetgetAcquiregetAndAccumulategetAndAddgetAndDecrementgetAndIncrementgetAndSetgetAndUpdategetOpaquegetPlainincrementAndGetintValuelazySetlongValuesetsetOpaquesetPlainsetReleasetoStringupdateAndGetweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

cancelledback to summary
pack-priv volatile boolean cancelled
doneback to summary
pack-priv volatile boolean done
errorModeback to summary
pack-priv final ErrorMode errorMode
errorsback to summary
pack-priv final AtomicThrowable errors
prefetchback to summary
pack-priv final int prefetch
queueback to summary
pack-priv SimpleQueue<T> queue
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

syncFusedback to summary
pack-priv boolean syncFused
upstreamback to summary
pack-priv Subscription upstream

Constructor Detail

ConcatMapXMainSubscriberback to summary
public ConcatMapXMainSubscriber(int prefetch, ErrorMode errorMode)

Method Detail

clearValueback to summary
pack-priv void clearValue()

Override this to clear values when the downstream disposes.

disposeInnerback to summary
pack-priv abstract void disposeInner()

Typically, this should be inner.dispose().

drainback to summary
pack-priv abstract void drain()

Implement the serialized inner subscribing and value emission here.

onCompleteback to summary
public final void onComplete()

Implements org.reactivestreams.Subscriber.onComplete.

Doc from org.reactivestreams.Subscriber.onComplete.

Successful terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

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

Implements org.reactivestreams.Subscriber.onError.

Doc from org.reactivestreams.Subscriber.onError.

Failed terminal state.

No further events will be sent even if Subscription#request(long) is invoked again.

Parameters
t:Throwable

the throwable signaled

Annotations
@Override
onNextback to summary
public final void onNext(T t)

Implements org.reactivestreams.Subscriber.onNext.

Doc from org.reactivestreams.Subscriber.onNext.

Data notification sent by the Publisher in response to requests to Subscription#request(long).

Parameters
t:T

the element signaled

Annotations
@Override
onSubscribeback to summary
public final void onSubscribe(Subscription s)

Implements org.reactivestreams.Subscriber.onSubscribe.

Doc from org.reactivestreams.Subscriber.onSubscribe.

Invoked after calling Publisher#subscribe(Subscriber).

No data will start flowing until Subscription#request(long) is invoked.

It is the responsibility of this Subscriber instance to call Subscription#request(long) whenever more data is wanted.

The Publisher will send notifications only in response to Subscription#request(long).

Parameters
s:Subscription

the Subscription that allows requesting data via Subscription#request(long)

Annotations
@Override
onSubscribeDownstreamback to summary
pack-priv abstract void onSubscribeDownstream()

Typically, this should be downstream.onSubscribe(this);.

stopback to summary
pack-priv final void stop()