Class FlowableConcatMap.ConcatMapDelayed<T,R>
- java.lang.Object
-
- java.lang.Number
-
- java.util.concurrent.atomic.AtomicInteger
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMap.BaseConcatMapSubscriber<T,R>
-
- io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMap.ConcatMapDelayed<T,R>
-
- All Implemented Interfaces:
FlowableSubscriber<T>
,FlowableConcatMap.ConcatMapSupport<R>
,java.io.Serializable
,org.reactivestreams.Subscriber<T>
,org.reactivestreams.Subscription
- Enclosing class:
- FlowableConcatMap<T,R>
static final class FlowableConcatMap.ConcatMapDelayed<T,R> extends FlowableConcatMap.BaseConcatMapSubscriber<T,R>
-
-
Field Summary
Fields Modifier and Type Field Description (package private) org.reactivestreams.Subscriber<? super R>
downstream
private static long
serialVersionUID
(package private) boolean
veryEnd
-
Constructor Summary
Constructors Constructor Description ConcatMapDelayed(org.reactivestreams.Subscriber<? super R> actual, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, boolean veryEnd)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
cancel()
(package private) void
drain()
void
innerError(java.lang.Throwable e)
void
innerNext(R value)
void
onError(java.lang.Throwable t)
void
request(long n)
(package private) void
subscribeActual()
-
Methods inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMap.BaseConcatMapSubscriber
innerComplete, onComplete, onNext, onSubscribe
-
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
-
veryEnd
final boolean veryEnd
-
-
Method Detail
-
subscribeActual
void subscribeActual()
- Specified by:
subscribeActual
in classFlowableConcatMap.BaseConcatMapSubscriber<T,R>
-
onError
public void onError(java.lang.Throwable t)
-
innerNext
public void innerNext(R value)
-
innerError
public void innerError(java.lang.Throwable e)
-
request
public void request(long n)
-
cancel
public void cancel()
-
drain
void drain()
- Specified by:
drain
in classFlowableConcatMap.BaseConcatMapSubscriber<T,R>
-
-