Class FlowableConcatMapSingle.ConcatMapSingleSubscriber<T,R>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainSubscriber<T>

io.reactivex.rxjava3.internal.operators.mixed.FlowableConcatMapSingle.ConcatMapSingleSubscriber<T,R>

All Implemented Interfaces:

FlowableSubscriber<T>, Serializable, org.reactivestreams.Subscriber<T>, org.reactivestreams.Subscription

Enclosing class:

FlowableConcatMapSingle<T,R>

static final class FlowableConcatMapSingle.ConcatMapSingleSubscriber<T,R>
extends ConcatMapXMainSubscriber<T>
implements org.reactivestreams.Subscription

Since:

2.2

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	FlowableConcatMapSingle.ConcatMapSingleSubscriber.ConcatMapSingleObserver<R>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) int	consumed
(package private) final org.reactivestreams.Subscriber<? super R>	downstream
(package private) long	emitted
(package private) final FlowableConcatMapSingle.ConcatMapSingleSubscriber.ConcatMapSingleObserver<R>	inner
(package private) R	item
(package private) final Function<? super T, ? extends SingleSource<? extends R>>	mapper
(package private) final AtomicLong	requested
private static final long	serialVersionUID
(package private) int	state
(package private) static final int	STATE_ACTIVE	An inner SingleSource is running but there are no results yet.
(package private) static final int	STATE_INACTIVE	No inner SingleSource is running.
(package private) static final int	STATE_RESULT_VALUE	The inner SingleSource succeeded with a value in item.

Fields inherited from class ConcatMapXMainSubscriber

cancelled, done, errorMode, errors, prefetch, queue, syncFused, upstream

Constructor Summary

Constructors

Constructor	Description
ConcatMapSingleSubscriber(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends SingleSource<? extends R>> mapper, int prefetch, ErrorMode errorMode)

Method Summary

Modifier and Type	Method	Description
void	cancel()
(package private) void	clearValue()	Override this to clear values when the downstream disposes.
(package private) void	disposeInner()	Typically, this should be inner.dispose().
(package private) void	drain()	Implement the serialized inner subscribing and value emission here.
(package private) void	innerError(Throwable ex)
(package private) void	innerSuccess(R item)
(package private) void	onSubscribeDownstream()	Typically, this should be downstream.onSubscribe(this);.
void	request(long n)

Methods inherited from class ConcatMapXMainSubscriber

onComplete, onError, onNext, onSubscribe, stop

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

mapper

final Function<? super T, ? extends SingleSource<? extends R>> mapper

requested

final AtomicLong requested

inner

final FlowableConcatMapSingle.ConcatMapSingleSubscriber.ConcatMapSingleObserver<R> inner

emitted

long emitted

consumed

int consumed

item

R item

state

volatile int state

STATE_INACTIVE

static final int STATE_INACTIVE

No inner SingleSource is running.

See Also:

• Constant Field Values

STATE_ACTIVE

static final int STATE_ACTIVE

An inner SingleSource is running but there are no results yet.

See Also:

• Constant Field Values

STATE_RESULT_VALUE

static final int STATE_RESULT_VALUE

The inner SingleSource succeeded with a value in item.

See Also:

• Constant Field Values

Constructor Details

ConcatMapSingleSubscriber

ConcatMapSingleSubscriber(org.reactivestreams.Subscriber<? super R> downstream,
 Function<? super T, ? extends SingleSource<? extends R>> mapper,
 int prefetch,
 ErrorMode errorMode)

Method Details

onSubscribeDownstream

void onSubscribeDownstream()

Description copied from class: ConcatMapXMainSubscriber

Typically, this should be downstream.onSubscribe(this);.

Specified by:

onSubscribeDownstream in class ConcatMapXMainSubscriber<T>

request

public void request(long n)

Specified by:

request in interface org.reactivestreams.Subscription

cancel

public void cancel()

Specified by:

cancel in interface org.reactivestreams.Subscription

clearValue

void clearValue()

Description copied from class: ConcatMapXMainSubscriber

Override this to clear values when the downstream disposes.

Overrides:

clearValue in class ConcatMapXMainSubscriber<T>

disposeInner

void disposeInner()

Description copied from class: ConcatMapXMainSubscriber

Typically, this should be inner.dispose().

Specified by:

disposeInner in class ConcatMapXMainSubscriber<T>

innerSuccess

void innerSuccess(R item)

innerError

void innerError(Throwable ex)

drain

void drain()

Description copied from class: ConcatMapXMainSubscriber

Implement the serialized inner subscribing and value emission here.

Specified by:

drain in class ConcatMapXMainSubscriber<T>