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 ClassesModifier and TypeClassDescription(package private) static final class
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) boolean
(package private) final CompletableObserver
(package private) final ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver
(package private) final Function
<? super T, ? extends CompletableSource> private static final long
-
Constructor Summary
ConstructorsConstructorDescriptionConcatMapCompletableObserver
(CompletableObserver downstream, Function<? super T, ? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch) -
Method Summary
Modifier and TypeMethodDescription(package private) void
Typically, this should beinner.dispose()
.(package private) void
drain()
Implement the serialized inner subscribing and value emission here.(package private) void
(package private) void
innerError
(Throwable ex) (package private) void
Typically, this should bedownstream.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
-
Field Details
-
serialVersionUID
private static final long serialVersionUID- See Also:
-
downstream
-
mapper
-
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 bedownstream.onSubscribe(this)
.- Specified by:
onSubscribeDownstream
in classConcatMapXMainObserver<T>
-
disposeInner
void disposeInner()Description copied from class:ConcatMapXMainObserver
Typically, this should beinner.dispose()
.- Specified by:
disposeInner
in classConcatMapXMainObserver<T>
-
innerError
-
innerComplete
void innerComplete() -
drain
void drain()Description copied from class:ConcatMapXMainObserver
Implement the serialized inner subscribing and value emission here.- Specified by:
drain
in classConcatMapXMainObserver<T>
-