Class FlowableConcatMap.BaseConcatMapSubscriber<T,R>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicInteger
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMap.BaseConcatMapSubscriber<T,R>
-
- All Implemented Interfaces:
FlowableSubscriber<T>
,FlowableConcatMap.ConcatMapSupport<R>
,java.io.Serializable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Direct Known Subclasses:
FlowableConcatMap.ConcatMapDelayed
,FlowableConcatMap.ConcatMapImmediate
- Enclosing class:
- FlowableConcatMap<T,R>
abstract static class FlowableConcatMap.BaseConcatMapSubscriber<T,R> extends java.util.concurrent.atomic.AtomicInteger implements FlowableSubscriber<T>, FlowableConcatMap.ConcatMapSupport<R>, org.reactivestreams.Subscription
-
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
active
(package private) boolean
cancelled
(package private) int
consumed
(package private) boolean
done
(package private) AtomicThrowable
errors
(package private) FlowableConcatMap.ConcatMapInner<R>
inner
(package private) int
limit
(package private) Function<? super T,? extends org.reactivestreams.Publisher<? extends R>>
mapper
(package private) int
prefetch
(package private) SimpleQueue<T>
queue
private static long
serialVersionUID
(package private) int
sourceMode
(package private) org.reactivestreams.Subscription
upstream
-
Constructor Summary
Constructors Constructor Description BaseConcatMapSubscriber(Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description (package private) abstract void
drain()
void
innerComplete()
void
onComplete()
void
onNext(T t)
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
subscribeActual()
-
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.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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
inner
final FlowableConcatMap.ConcatMapInner<R> inner
-
prefetch
final int prefetch
-
limit
final int limit
-
upstream
org.reactivestreams.Subscription upstream
-
consumed
int consumed
-
queue
SimpleQueue<T> queue
-
done
volatile boolean done
-
cancelled
volatile boolean cancelled
-
errors
final AtomicThrowable errors
-
active
volatile boolean active
-
sourceMode
int sourceMode
-
-
Method Detail
-
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>
-
drain
abstract void drain()
-
subscribeActual
abstract void subscribeActual()
-
onNext
public final void onNext(T t)
- 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>
-
-