Class FlowableConcatMapScheduler.BaseConcatMapSubscriber<T,R>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMapScheduler.BaseConcatMapSubscriber<T,R>
- All Implemented Interfaces:
FlowableSubscriber<T>
,FlowableConcatMap.ConcatMapSupport<R>
,Serializable
,Runnable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Direct Known Subclasses:
FlowableConcatMapScheduler.ConcatMapDelayed
,FlowableConcatMapScheduler.ConcatMapImmediate
- Enclosing class:
FlowableConcatMapScheduler<T,
R>
abstract static class FlowableConcatMapScheduler.BaseConcatMapSubscriber<T,R>
extends AtomicInteger
implements FlowableSubscriber<T>, FlowableConcatMap.ConcatMapSupport<R>, org.reactivestreams.Subscription, Runnable
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) boolean
(package private) int
(package private) boolean
(package private) final AtomicThrowable
(package private) final FlowableConcatMap.ConcatMapInner
<R> (package private) final int
(package private) final int
(package private) SimpleQueue
<T> private static final long
(package private) int
(package private) org.reactivestreams.Subscription
(package private) final Scheduler.Worker
-
Constructor Summary
ConstructorsConstructorDescriptionBaseConcatMapSubscriber
(Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, Scheduler.Worker worker) -
Method Summary
Modifier and TypeMethodDescriptionfinal void
final void
final void
final void
onSubscribe
(org.reactivestreams.Subscription s) Implementors of this method should make sure everything that needs to be visible inSubscriber.onNext(Object)
is established before callingSubscription.request(long)
.(package private) abstract void
schedule()
(package private) abstract void
Methods inherited from class java.util.concurrent.atomic.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 java.lang.Number
byteValue, shortValue
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMap.ConcatMapSupport
innerError, innerNext
Methods inherited from interface org.reactivestreams.Subscriber
onError
Methods inherited from interface org.reactivestreams.Subscription
cancel, request
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
inner
-
mapper
-
prefetch
final int prefetch -
limit
final int limit -
worker
-
upstream
org.reactivestreams.Subscription upstream -
consumed
int consumed -
queue
SimpleQueue<T> queue -
done
volatile boolean done -
cancelled
volatile boolean cancelled -
errors
-
active
volatile boolean active -
sourceMode
int sourceMode
-
-
Constructor Details
-
BaseConcatMapSubscriber
BaseConcatMapSubscriber(Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, Scheduler.Worker worker)
-
-
Method Details
-
onSubscribe
public final void onSubscribe(org.reactivestreams.Subscription s) Description copied from interface:FlowableSubscriber
Implementors of this method should make sure everything that needs to be visible inSubscriber.onNext(Object)
is established before callingSubscription.request(long)
. In practice this means no initialization should happen after therequest()
call and additional behavior is thread safe in respect toonNext
.- Specified by:
onSubscribe
in interfaceFlowableSubscriber<T>
- Specified by:
onSubscribe
in interfaceorg.reactivestreams.Subscriber<T>
-
schedule
abstract void schedule() -
subscribeActual
abstract void subscribeActual() -
onNext
- Specified by:
onNext
in interfaceorg.reactivestreams.Subscriber<T>
-
onComplete
public final void onComplete()- Specified by:
onComplete
in interfaceorg.reactivestreams.Subscriber<T>
-
innerComplete
public final void innerComplete()- Specified by:
innerComplete
in interfaceFlowableConcatMap.ConcatMapSupport<T>
-