Class FlowableConcatMapSingle.ConcatMapSingleSubscriber<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.FlowableConcatMapSingle.ConcatMapSingleSubscriber<T,R>
-
- All Implemented Interfaces:
FlowableSubscriber<T>
,java.io.Serializable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
- FlowableConcatMapSingle<T,R>
static final class FlowableConcatMapSingle.ConcatMapSingleSubscriber<T,R> extends ConcatMapXMainSubscriber<T> implements org.reactivestreams.Subscription
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
FlowableConcatMapSingle.ConcatMapSingleSubscriber.ConcatMapSingleObserver<R>
-
Field Summary
Fields Modifier and Type Field Description (package private) int
consumed
(package private) org.reactivestreams.Subscriber<? super R>
downstream
(package private) long
emitted
(package private) FlowableConcatMapSingle.ConcatMapSingleSubscriber.ConcatMapSingleObserver<R>
inner
(package private) R
item
(package private) Function<? super T,? extends SingleSource<? extends R>>
mapper
(package private) java.util.concurrent.atomic.AtomicLong
requested
private static long
serialVersionUID
(package private) int
state
(package private) static int
STATE_ACTIVE
An inner SingleSource is running but there are no results yet.(package private) static int
STATE_INACTIVE
No inner SingleSource is running.(package private) static int
STATE_RESULT_VALUE
The inner SingleSource succeeded with a value initem
.
-
Constructor Summary
Constructors Constructor Description ConcatMapSingleSubscriber(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T,? extends SingleSource<? extends R>> mapper, int prefetch, ErrorMode errorMode)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
(package private) void
clearValue()
Override this to clear values when the downstream disposes.(package private) void
disposeInner()
Typically, this should beinner.dispose()
.(package private) void
drain()
Implement the serialized inner subscribing and value emission here.(package private) void
innerError(java.lang.Throwable ex)
(package private) void
innerSuccess(R item)
(package private) void
onSubscribeDownstream()
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
-
-
-
-
Field Detail
-
serialVersionUID
private static final long serialVersionUID
- See Also:
- Constant Field Values
-
downstream
final org.reactivestreams.Subscriber<? super R> downstream
-
mapper
final Function<? super T,? extends SingleSource<? extends R>> mapper
-
requested
final java.util.concurrent.atomic.AtomicLong requested
-
inner
final FlowableConcatMapSingle.ConcatMapSingleSubscriber.ConcatMapSingleObserver<R> inner
-
emitted
long emitted
-
consumed
int consumed
-
item
R item
-
state
volatile int state
-
STATE_INACTIVE
static final int STATE_INACTIVE
No inner SingleSource is running.- See Also:
- Constant Field Values
-
STATE_ACTIVE
static final int STATE_ACTIVE
An inner SingleSource is running but there are no results yet.- See Also:
- Constant Field Values
-
STATE_RESULT_VALUE
static final int STATE_RESULT_VALUE
The inner SingleSource succeeded with a value initem
.- See Also:
- Constant Field Values
-
-
Method Detail
-
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
-
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>
-
innerSuccess
void innerSuccess(R item)
-
innerError
void innerError(java.lang.Throwable ex)
-
drain
void drain()
Description copied from class:ConcatMapXMainSubscriber
Implement the serialized inner subscribing and value emission here.- Specified by:
drain
in classConcatMapXMainSubscriber<T>
-
-