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

Class FlowableConcatMap.ConcatMapImmediate<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.ConcatMapImmediate<T,R>

All Implemented Interfaces:

FlowableSubscriber<T>, FlowableConcatMap.ConcatMapSupport<R>, Serializable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

Enclosing class:

FlowableConcatMap<T,R>

static final class FlowableConcatMap.ConcatMapImmediate<T,R>
extends FlowableConcatMap.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.FlowableConcatMap.BaseConcatMapSubscriber

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	cancel()
(package private) void	drain()
void	innerError(Throwable e)
void	innerNext(R value)
void	onError(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

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)

Method Details

subscribeActual

void subscribeActual()

Specified by:

subscribeActual in class FlowableConcatMap.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()

drain

void drain()

Specified by:

drain in class FlowableConcatMap.BaseConcatMapSubscriber<T,R>