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
,java.io.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 class
ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver
-
Field Summary
Fields Modifier and Type Field Description (package private) boolean
active
(package private) CompletableObserver
downstream
(package private) ObservableConcatMapCompletable.ConcatMapCompletableObserver.ConcatMapInnerObserver
inner
(package private) Function<? super T,? extends CompletableSource>
mapper
private static long
serialVersionUID
-
Constructor Summary
Constructors Constructor Description ConcatMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description (package private) void
disposeInner()
Typically, this should beinner.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
onSubscribeDownstream()
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
-
-
-
-
Field Detail
-
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 Detail
-
ConcatMapCompletableObserver
ConcatMapCompletableObserver(CompletableObserver downstream, Function<? super T,? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch)
-
-
Method Detail
-
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
void innerError(java.lang.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 classConcatMapXMainObserver<T>
-
-