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