Class FlowableConcatMapMaybe.ConcatMapMaybeSubscriber<T,R>
java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainSubscriber<T>
io.reactivex.rxjava3.internal.operators.mixed.FlowableConcatMapMaybe.ConcatMapMaybeSubscriber<T,R>
- All Implemented Interfaces:
FlowableSubscriber<T>
,Serializable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
FlowableConcatMapMaybe<T,
R>
static final class FlowableConcatMapMaybe.ConcatMapMaybeSubscriber<T,R>
extends ConcatMapXMainSubscriber<T>
implements org.reactivestreams.Subscription
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) int
(package private) final org.reactivestreams.Subscriber
<? super R> (package private) long
(package private) final FlowableConcatMapMaybe.ConcatMapMaybeSubscriber.ConcatMapMaybeObserver
<R> (package private) R
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> (package private) final AtomicLong
private static final long
(package private) int
(package private) static final int
An inner MaybeSource is running but there are no results yet.(package private) static final int
No inner MaybeSource is running.(package private) static final int
The inner MaybeSource succeeded with a value initem
. -
Constructor Summary
ConstructorsConstructorDescriptionConcatMapMaybeSubscriber
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, int prefetch, ErrorMode errorMode) -
Method Summary
Modifier and TypeMethodDescriptionvoid
cancel()
(package private) void
Override this to clear values when the downstream disposes.(package private) void
Typically, this should beinner.dispose()
.(package private) void
drain()
Implement the serialized inner subscribing and value emission here.(package private) void
(package private) void
innerError
(Throwable ex) (package private) void
innerSuccess
(R item) (package private) void
Typically, this should bedownstream.onSubscribe(this);
.void
request
(long n) Methods inherited from class io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainSubscriber
onComplete, onError, onNext, onSubscribe, stop
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
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
downstream
-
mapper
-
requested
-
inner
-
emitted
long emitted -
consumed
int consumed -
item
R item -
state
volatile int state -
STATE_INACTIVE
static final int STATE_INACTIVENo inner MaybeSource is running.- See Also:
-
STATE_ACTIVE
static final int STATE_ACTIVEAn inner MaybeSource is running but there are no results yet.- See Also:
-
STATE_RESULT_VALUE
static final int STATE_RESULT_VALUEThe inner MaybeSource succeeded with a value initem
.- See Also:
-
-
Constructor Details
-
ConcatMapMaybeSubscriber
-
-
Method Details
-
onSubscribeDownstream
void onSubscribeDownstream()Description copied from class:ConcatMapXMainSubscriber
Typically, this should bedownstream.onSubscribe(this);
.- Specified by:
onSubscribeDownstream
in classConcatMapXMainSubscriber<T>
-
request
public void request(long n) - Specified by:
request
in interfaceorg.reactivestreams.Subscription
-
cancel
public void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-
innerSuccess
-
innerComplete
void innerComplete() -
innerError
-
clearValue
void clearValue()Description copied from class:ConcatMapXMainSubscriber
Override this to clear values when the downstream disposes.- Overrides:
clearValue
in classConcatMapXMainSubscriber<T>
-
disposeInner
void disposeInner()Description copied from class:ConcatMapXMainSubscriber
Typically, this should beinner.dispose()
.- Specified by:
disposeInner
in classConcatMapXMainSubscriber<T>
-
drain
void drain()Description copied from class:ConcatMapXMainSubscriber
Implement the serialized inner subscribing and value emission here.- Specified by:
drain
in classConcatMapXMainSubscriber<T>
-