Package io.reactivex.rxjava3.internal.operators.mixed

Class ObservableConcatMapMaybe.ConcatMapMaybeMainObserver<T,R>

java.lang.Object

java.lang.Number

java.util.concurrent.atomic.AtomicInteger

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

io.reactivex.rxjava3.internal.operators.mixed.ObservableConcatMapMaybe.ConcatMapMaybeMainObserver<T,R>

All Implemented Interfaces:

Observer<T>, Disposable, java.io.Serializable

Enclosing class:

ObservableConcatMapMaybe<T,R>

static final class ObservableConcatMapMaybe.ConcatMapMaybeMainObserver<T,R>
extends ConcatMapXMainObserver<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.ConcatMapMaybeObserver<R>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) Observer<? super R>	downstream
(package private) ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.ConcatMapMaybeObserver<R>	inner
(package private) R	item
(package private) Function<? super T,? extends MaybeSource<? extends R>>	mapper
private static long	serialVersionUID
(package private) int	state
(package private) static int	STATE_ACTIVE	An inner MaybeSource is running but there are no results yet.
(package private) static int	STATE_INACTIVE	No inner MaybeSource is running.
(package private) static int	STATE_RESULT_VALUE	The inner MaybeSource succeeded with a value in item.

Fields inherited from class io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver

disposed, done, errorMode, errors, prefetch, queue, upstream

Constructor Summary

Constructors

Constructor	Description
ConcatMapMaybeMainObserver(Observer<? super R> downstream, Function<? super T,? extends MaybeSource<? extends R>> mapper, int prefetch, ErrorMode errorMode)

Method Summary

Modifier and Type	Method	Description
(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	innerComplete()
(package private) void	innerError(java.lang.Throwable ex)
(package private) void	innerSuccess(R item)
(package private) void	onSubscribeDownstream()	Typically, this should be downstream.onSubscribe(this).

Methods inherited from class io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver

dispose, isDisposed, onComplete, onError, 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 Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

downstream

final Observer<? super R> downstream

mapper

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

inner

final ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.ConcatMapMaybeObserver<R> inner

item

R item

state

volatile int state

STATE_INACTIVE

static final int STATE_INACTIVE

No inner MaybeSource is running.

See Also:

Constant Field Values

STATE_ACTIVE

static final int STATE_ACTIVE

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

See Also:

Constant Field Values

STATE_RESULT_VALUE

static final int STATE_RESULT_VALUE

The inner MaybeSource succeeded with a value in item.

See Also:

Constant Field Values

Constructor Detail

ConcatMapMaybeMainObserver

ConcatMapMaybeMainObserver(Observer<? super R> downstream,
                           Function<? super T,? extends MaybeSource<? extends R>> mapper,
                           int prefetch,
                           ErrorMode errorMode)

Method Detail

onSubscribeDownstream

void onSubscribeDownstream()

Description copied from class: ConcatMapXMainObserver

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

Specified by:

onSubscribeDownstream in class ConcatMapXMainObserver<T>

clearValue

void clearValue()

Description copied from class: ConcatMapXMainObserver

Override this to clear values when the downstream disposes.

Overrides:

clearValue in class ConcatMapXMainObserver<T>

innerSuccess

void innerSuccess(R item)

innerComplete

void innerComplete()

innerError

void innerError(java.lang.Throwable ex)

disposeInner

void disposeInner()

Description copied from class: ConcatMapXMainObserver

Typically, this should be inner.dispose().

Specified by:

disposeInner in class ConcatMapXMainObserver<T>

drain

void drain()

Description copied from class: ConcatMapXMainObserver

Implement the serialized inner subscribing and value emission here.

Specified by:

drain in class ConcatMapXMainObserver<T>