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

Class ObservableConcatMapCompletable.ConcatMapCompletableObserver<T>

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.ObservableConcatMapCompletable.ConcatMapCompletableObserver<T>

All Implemented Interfaces:

Observer<T>, Disposable, Serializable

Enclosing class:

ObservableConcatMapCompletable<T>

static final class ObservableConcatMapCompletable.ConcatMapCompletableObserver<T>
extends ConcatMapXMainObserver<T>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	active
(package private) final CompletableObserver	downstream
(package private) final ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver	inner
(package private) final Function<? super T,? extends CompletableSource>	mapper
private static final long	serialVersionUID

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

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

Constructor Summary

Constructors

Constructor	Description
ConcatMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)

Method Summary

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

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

clearValue, 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 Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

downstream

final CompletableObserver downstream

mapper

final Function<? super T,? extends CompletableSource> mapper

inner

final ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver inner

active

volatile boolean active

Constructor Details

ConcatMapCompletableObserver

ConcatMapCompletableObserver(CompletableObserver downstream,
 Function<? super T,? extends CompletableSource> mapper,
 ErrorMode errorMode,
 int prefetch)

Method Details

onSubscribeDownstream

void onSubscribeDownstream()

Description copied from class: ConcatMapXMainObserver

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

Specified by:

onSubscribeDownstream in class ConcatMapXMainObserver<T>

disposeInner

void disposeInner()

Description copied from class: ConcatMapXMainObserver

Typically, this should be inner.dispose().

Specified by:

disposeInner in class ConcatMapXMainObserver<T>

innerError

void innerError(Throwable ex)

innerComplete

void innerComplete()

drain

void drain()

Description copied from class: ConcatMapXMainObserver

Implement the serialized inner subscribing and value emission here.

Specified by:

drain in class ConcatMapXMainObserver<T>