Package io.reactivex.rxjava3.internal.operators.flowable

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

Fields inherited from class io.reactivex.rxjava3.internal.operators.flowable.FlowableConcatMapScheduler.BaseConcatMapSubscriber

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

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

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()
(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

Methods inherited from class java.lang.Number

byteValue, shortValue

Methods inherited from class java.lang.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

wip

final AtomicInteger wip

Constructor Details

ConcatMapImmediate

ConcatMapImmediate(org.reactivestreams.Subscriber<? super R> actual,
 Function<? super T,? extends org.reactivestreams.Publisher<? extends R>> mapper,
 int prefetch,
 Scheduler.Worker worker)

Method Details

subscribeActual

void subscribeActual()

Specified by:

subscribeActual in class FlowableConcatMapScheduler.BaseConcatMapSubscriber<T,R>

onError

public void onError(Throwable t)

tryEnter

boolean tryEnter()

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()