Class FlowableConcatMapScheduler.ConcatMapImmediate<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.ConcatMapImmediate<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.ConcatMapImmediate<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) java.util.concurrent.atomic.AtomicInteger
wip
-
Constructor Summary
Constructors Constructor Description ConcatMapImmediate(org.reactivestreams.Subscriber<? super R> actual, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, 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()
(package private) boolean
tryEnter()
-
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
-
wip
final java.util.concurrent.atomic.AtomicInteger wip
-
-
Constructor Detail
-
ConcatMapImmediate
ConcatMapImmediate(org.reactivestreams.Subscriber<? super R> actual, Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, Scheduler.Worker worker)
-
-
Method Detail
-
subscribeActual
void subscribeActual()
- Specified by:
subscribeActual
in classFlowableConcatMapScheduler.BaseConcatMapSubscriber<T,R>
-
onError
public void onError(java.lang.Throwable t)
-
tryEnter
boolean tryEnter()
-
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()
-
-