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>, Serializable, 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) final org.reactivestreams.Subscriber<? super R>	downstream
private static final long	serialVersionUID
(package private) final boolean	veryEnd

Fields inherited from class FlowableConcatMapScheduler.BaseConcatMapSubscriber

active, cancelled, consumed, done, errors, inner, limit, mapper, prefetch, queue, sourceMode, upstream, worker

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

Modifier and Type	Method	Description
void	cancel()
void	innerError(Throwable e)
void	innerNext(R value)
void	onError(Throwable t)
void	request(long n)
void	run()
(package private) void	schedule()
(package private) void	subscribeActual()

Methods inherited from class FlowableConcatMapScheduler.BaseConcatMapSubscriber

innerComplete, onComplete, onNext, onSubscribe

Methods inherited from class 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 Number

byteValue, shortValue

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

downstream

final org.reactivestreams.Subscriber<? super R> downstream

veryEnd

final boolean veryEnd

Constructor Details

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 Details

subscribeActual

void subscribeActual()

Specified by:

subscribeActual in class FlowableConcatMapScheduler.BaseConcatMapSubscriber<T,R>

onError

public void onError(Throwable t)

innerNext

public void innerNext(R value)

innerError

public void innerError(Throwable e)

request

public void request(long n)

cancel

public void cancel()

schedule

void schedule()

Specified by:

schedule in class FlowableConcatMapScheduler.BaseConcatMapSubscriber<T,R>

run

public void run()