Top Description Inners Fields Constructors Methods
io.reactivex.rxjava3.internal.operators.mixed

public final Class ObservableConcatMapMaybe<T, R>

extends Observable<R>
Class Inheritance
Type Parameters
<T>
the upstream element type
<R>
the output element type
Imports
java.util.Objects, java.util.concurrent.atomic.AtomicReference, io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.exceptions.Exceptions, io.reactivex.rxjava3.functions.Function, io.reactivex.rxjava3.internal.disposables.DisposableHelper, io.reactivex.rxjava3.internal.util.*, io.reactivex.rxjava3.operators.SimpleQueue

Maps each upstream item into a MaybeSource, subscribes to them one after the other terminates and relays their success values, optionally delaying any errors till the main and inner sources terminate.

History: 2.1.11 - experimental

Since
2.2

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class

Field Summary

Modifier and TypeField and Description
pack-priv final ErrorMode
pack-priv final Function<? super T, ? extends MaybeSource<? extends R>>
pack-priv final int
pack-priv final Observable<T>

Constructor Summary

AccessConstructor and Description
public
ObservableConcatMapMaybe(Observable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch)

Method Summary

Modifier and TypeMethod and Description
protected void
subscribeActual(Observer<? super R> observer)

Inherited from io.reactivex.rxjava3.core.Observable:
allambambArrayambWithanyblockingFirstblockingFirstblockingForEachblockingForEachblockingIterableblockingIterableblockingLastblockingLastblockingLatestblockingMostRecentblockingNextblockingSingleblockingSingleblockingStreamblockingStreamblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribebufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferbufferSizecachecacheWithInitialCapacitycastcollectcollectcollectIntocombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestcombineLatestArraycombineLatestArraycombineLatestArrayDelayErrorcombineLatestArrayDelayErrorcombineLatestDelayErrorcombineLatestDelayErrorcomposeconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatArrayEagerconcatArrayEagerconcatArrayEagerDelayErrorconcatArrayEagerDelayErrorconcatDelayErrorconcatDelayErrorconcatDelayErrorconcatEagerconcatEagerconcatEagerconcatEagerconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatMapconcatMapconcatMapconcatMapCompletableconcatMapCompletableconcatMapCompletableDelayErrorconcatMapCompletableDelayErrorconcatMapCompletableDelayErrorconcatMapDelayErrorconcatMapDelayErrorconcatMapDelayErrorconcatMapEagerconcatMapEagerconcatMapEagerDelayErrorconcatMapEagerDelayErrorconcatMapIterableconcatMapMaybeconcatMapMaybeconcatMapMaybeDelayErrorconcatMapMaybeDelayErrorconcatMapMaybeDelayErrorconcatMapSingleconcatMapSingleconcatMapSingleDelayErrorconcatMapSingleDelayErrorconcatMapSingleDelayErrorconcatMapStreamconcatWithconcatWithconcatWithconcatWithcontainscountcreatedebouncedebouncedebouncedebouncedefaultIfEmptydeferdelaydelaydelaydelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondematerializedistinctdistinctdistinctdistinctUntilChangeddistinctUntilChangeddistinctUntilChangeddoAfterNextdoAfterTerminatedoFinallydoOnCompletedoOnDisposedoOnEachdoOnEachdoOnErrordoOnLifecycledoOnNextdoOnSubscribedoOnTerminateelementAtelementAtelementAtOrErroremptyerrorerrorfilterfirstfirstElementfirstOrErrorfirstOrErrorStagefirstStageflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapflatMapCompletableflatMapCompletableflatMapIterableflatMapIterableflatMapMaybeflatMapMaybeflatMapSingleflatMapSingleflatMapStreamforEachforEachWhileforEachWhileforEachWhilefromActionfromArrayfromCallablefromCompletablefromCompletionStagefromFuturefromFuturefromIterablefromMaybefromOptionalfromPublisherfromRunnablefromSinglefromStreamfromSuppliergenerategenerategenerategenerategenerategroupBygroupBygroupBygroupBygroupBygroupJoinhideignoreElementsintervalintervalintervalintervalintervalRangeintervalRangeisEmptyjoinjustjustjustjustjustjustjustjustjustjustlastlastElementlastOrErrorlastOrErrorStagelastStageliftmapmapOptionalmaterializemergemergemergemergemergemergemergemergemergeArraymergeArraymergeArrayDelayErrormergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithmergeWithmergeWithmergeWithneverobserveOnobserveOnobserveOnofTypeonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeWithonErrorReturnonErrorReturnItemonTerminateDetachpublishpublishrangerangeLongreducereducereduceWithrepeatrepeatrepeatUntilrepeatWhenreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayreplayretryretryretryretryretryretryUntilretryWhensafeSubscribesamplesamplesamplesamplesamplesamplesamplescanscanscanWithsequenceEqualsequenceEqualsequenceEqualsequenceEqualserializesharesinglesingleElementsingleOrErrorsingleOrErrorStagesingleStageskipskipskipskipLastskipLastskipLastskipLastskipLastskipLastskipUntilskipWhilesortedsortedstartWithstartWithstartWithstartWithstartWithArraystartWithItemstartWithIterablesubscribesubscribesubscribesubscribesubscribesubscribesubscribeActualsubscribeOnsubscribeWithswitchIfEmptyswitchMapswitchMapswitchMapCompletableswitchMapCompletableDelayErrorswitchMapDelayErrorswitchMapDelayErrorswitchMapMaybeswitchMapMaybeDelayErrorswitchMapSingleswitchMapSingleDelayErrorswitchOnNextswitchOnNextswitchOnNextDelayErrorswitchOnNextDelayErrortaketaketaketakeLasttakeLasttakeLasttakeLasttakeLasttakeLasttakeLasttakeLasttakeLasttakeUntiltakeUntiltakeWhiletesttestthrottleFirstthrottleFirstthrottleFirstthrottleLastthrottleLastthrottleLastthrottleLatestthrottleLatestthrottleLatestthrottleLatestthrottleLatestthrottleWithTimeoutthrottleWithTimeoutthrottleWithTimeouttimeIntervaltimeIntervaltimeIntervaltimeIntervaltimeouttimeouttimeouttimeouttimeouttimeouttimeouttimeouttimertimertimestamptimestamptimestamptimestamptotoFlowabletoFuturetoListtoListtoListtoMaptoMaptoMaptoMultimaptoMultimaptoMultimaptoMultimaptoSortedListtoSortedListtoSortedListtoSortedListunsafeCreateunsubscribeOnusingusingwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwindowwithLatestFromwithLatestFromwithLatestFromwithLatestFromwithLatestFromwithLatestFromwrapzipzipzipzipzipzipzipzipzipzipzipzipzipArrayzipWithzipWithzipWithzipWith

Field Detail

errorModeback to summary
pack-priv final ErrorMode errorMode
mapperback to summary
pack-priv final Function<? super T, ? extends MaybeSource<? extends R>> mapper
prefetchback to summary
pack-priv final int prefetch
sourceback to summary
pack-priv final Observable<T> source

Constructor Detail

ObservableConcatMapMaybeback to summary
public ObservableConcatMapMaybe(Observable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch)

Method Detail

subscribeActualback to summary
protected void subscribeActual(Observer<? super R> observer)
Annotations
@Override
io.reactivex.rxjava3.internal.operators.mixed back to summary

pack-priv final Class ObservableConcatMapMaybe.ConcatMapMaybeMainObserver<T, R>

extends ConcatMapXMainObserver<T>
Class Inheritance

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class

Field Summary

Modifier and TypeField and Description
pack-priv final Observer<? super R>
pack-priv final ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.ConcatMapMaybeObserver<R>
pack-priv R
pack-priv final Function<? super T, ? extends MaybeSource<? extends R>>
private static final long
pack-priv volatile int
pack-priv static final int
STATE_ACTIVE

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

pack-priv static final int
STATE_INACTIVE

No inner MaybeSource is running.

pack-priv static final int
STATE_RESULT_VALUE

The inner MaybeSource succeeded with a value in item.

Inherited from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver:
disposeddoneerrorModeerrorsprefetchqueueupstream

Constructor Summary

AccessConstructor and Description
pack-priv
ConcatMapMaybeMainObserver(Observer<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, int prefetch, ErrorMode errorMode)

Method Summary

Modifier and TypeMethod and Description
pack-priv void
clearValue()

Overrides io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.clearValue.

Override this to clear values when the downstream disposes.
pack-priv void
disposeInner()

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.disposeInner.

Typically, this should be inner.dispose().
pack-priv void
drain()

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.drain.

Implement the serialized inner subscribing and value emission here.
pack-priv void
pack-priv void
pack-priv void
innerSuccess(R item)

pack-priv void
onSubscribeDownstream()

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.onSubscribeDownstream.

Typically, this should be downstream.onSubscribe(this).
Inherited from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver:
disposeisDisposedonCompleteonErroronNextonSubscribe

Field Detail

downstreamback to summary
pack-priv final Observer<? super R> downstream
innerback to summary
pack-priv final ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.ConcatMapMaybeObserver<R> inner
itemback to summary
pack-priv R item
mapperback to summary
pack-priv final Function<? super T, ? extends MaybeSource<? extends R>> mapper
serialVersionUIDback to summary
private static final long serialVersionUID

Hides io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.serialVersionUID.

stateback to summary
pack-priv volatile int state
STATE_ACTIVEback to summary
pack-priv static final int STATE_ACTIVE

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

STATE_INACTIVEback to summary
pack-priv static final int STATE_INACTIVE

No inner MaybeSource is running.

STATE_RESULT_VALUEback to summary
pack-priv static final int STATE_RESULT_VALUE

The inner MaybeSource succeeded with a value in item.

Constructor Detail

ConcatMapMaybeMainObserverback to summary
pack-priv ConcatMapMaybeMainObserver(Observer<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, int prefetch, ErrorMode errorMode)

Method Detail

clearValueback to summary
pack-priv void clearValue()

Overrides io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.clearValue.

Doc from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.clearValue.

Override this to clear values when the downstream disposes.

Annotations
@Override
disposeInnerback to summary
pack-priv void disposeInner()

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.disposeInner.

Doc from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.disposeInner.

Typically, this should be inner.dispose().

Annotations
@Override
drainback to summary
pack-priv void drain()

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.drain.

Doc from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.drain.

Implement the serialized inner subscribing and value emission here.

Annotations
@Override
innerCompleteback to summary
pack-priv void innerComplete()
innerErrorback to summary
pack-priv void innerError(Throwable ex)
innerSuccessback to summary
pack-priv void innerSuccess(R item)
onSubscribeDownstreamback to summary
pack-priv void onSubscribeDownstream()

Implements abstract io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.onSubscribeDownstream.

Doc from io.reactivex.rxjava3.internal.operators.mixed.ConcatMapXMainObserver.onSubscribeDownstream.

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

Annotations
@Override
io.reactivex.rxjava3.internal.operators.mixed back to summary

pack-priv final Class ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.ConcatMapMaybeObserver<R>

extends AtomicReference<Disposable>
implements MaybeObserver<R>
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.core.MaybeObserver

Field Summary

Modifier and TypeField and Description
pack-priv final ObservableConcatMapMaybe.ConcatMapMaybeMainObserver<?, R>
private static final long

Constructor Summary

AccessConstructor and Description
pack-priv

Field Detail

parentback to summary
pack-priv final ObservableConcatMapMaybe.ConcatMapMaybeMainObserver<?, R> parent
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Detail

ConcatMapMaybeObserverback to summary
pack-priv ConcatMapMaybeObserver(ObservableConcatMapMaybe.ConcatMapMaybeMainObserver<?, R> parent)

Method Detail

disposeback to summary
pack-priv void dispose()
onCompleteback to summary
public void onComplete()

Implements io.reactivex.rxjava3.core.MaybeObserver.onComplete.

Doc from io.reactivex.rxjava3.core.MaybeObserver.onComplete.

Called once the deferred computation completes normally.

Annotations
@Override
onErrorback to summary
public void onError(Throwable e)
Annotations
@Override
onSubscribeback to summary
public void onSubscribe(Disposable d)
Annotations
@Override
onSuccessback to summary
public void onSuccess(R t)

Implements io.reactivex.rxjava3.core.MaybeObserver.onSuccess.

Doc from io.reactivex.rxjava3.core.MaybeObserver.onSuccess.

Notifies the MaybeObserver with one item and that the Maybe has finished sending push-based notifications.

The Maybe will not call this method if it calls onError.

Parameters
t:R

the item emitted by the Maybe

Annotations
@Override