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

public final Class ObservableConcatMapSingle<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 SingleSource, 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
ObservableConcatMapSingle.ConcatMapSingleMainObserver<T, R>

Field Summary

Modifier and TypeField and Description
pack-priv final ErrorMode
errorMode

pack-priv final Function<? super T, ? extends SingleSource<? extends R>>
mapper

pack-priv final int
prefetch

pack-priv final ObservableSource<T>
source

Constructor Summary

AccessConstructor and Description
public
ObservableConcatMapSingle(ObservableSource<T> source, Function<? super T, ? extends SingleSource<? 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 SingleSource<? extends R>> mapper
prefetchback to summary
pack-priv final int prefetch
sourceback to summary
pack-priv final ObservableSource<T> source

Constructor Detail

ObservableConcatMapSingleback to summary
public ObservableConcatMapSingle(ObservableSource<T> source, Function<? super T, ? extends SingleSource<? 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 ObservableConcatMapSingle.ConcatMapSingleMainObserver<T, R>

extends ConcatMapXMainObserver<T>
Class Inheritance

Nested and Inner Type Summary

Modifier and TypeClass and Description
pack-priv static class
ObservableConcatMapSingle.ConcatMapSingleMainObserver.ConcatMapSingleObserver<R>

Field Summary

Modifier and TypeField and Description
pack-priv final Observer<? super R>
downstream

pack-priv final ObservableConcatMapSingle.ConcatMapSingleMainObserver.ConcatMapSingleObserver<R>
inner

pack-priv R
item

pack-priv final Function<? super T, ? extends SingleSource<? extends R>>
mapper

private static final long
serialVersionUID

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

pack-priv volatile int
state

pack-priv static final int
STATE_ACTIVE

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

pack-priv static final int
STATE_INACTIVE

No inner SingleSource is running.

pack-priv static final int
STATE_RESULT_VALUE

The inner SingleSource succeeded with a value in item.

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

Constructor Summary

AccessConstructor and Description
pack-priv
ConcatMapSingleMainObserver(Observer<? super R> downstream, Function<? super T, ? extends SingleSource<? 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
innerError(Throwable ex)

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 ObservableConcatMapSingle.ConcatMapSingleMainObserver.ConcatMapSingleObserver<R> inner
itemback to summary
pack-priv R item
mapperback to summary
pack-priv final Function<? super T, ? extends SingleSource<? 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 SingleSource is running but there are no results yet.

STATE_INACTIVEback to summary
pack-priv static final int STATE_INACTIVE

No inner SingleSource is running.

STATE_RESULT_VALUEback to summary
pack-priv static final int STATE_RESULT_VALUE

The inner SingleSource succeeded with a value in item.

Constructor Detail

ConcatMapSingleMainObserverback to summary
pack-priv ConcatMapSingleMainObserver(Observer<? super R> downstream, Function<? super T, ? extends SingleSource<? 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
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 ObservableConcatMapSingle.ConcatMapSingleMainObserver.ConcatMapSingleObserver<R>

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

Field Summary

Modifier and TypeField and Description
pack-priv final ObservableConcatMapSingle.ConcatMapSingleMainObserver<?, R>
parent

private static final long
serialVersionUID

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

Constructor Summary

AccessConstructor and Description
pack-priv
ConcatMapSingleObserver(ObservableConcatMapSingle.ConcatMapSingleMainObserver<?, R> parent)

Field Detail

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

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

Constructor Detail

ConcatMapSingleObserverback to summary
pack-priv ConcatMapSingleObserver(ObservableConcatMapSingle.ConcatMapSingleMainObserver<?, R> parent)

Method Detail

disposeback to summary
pack-priv void dispose()
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.SingleObserver.onSuccess.

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

Notifies the SingleObserver with a single item and that the Single has finished sending push-based notifications.

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

Parameters
t:R

the item emitted by the Single

Annotations
@Override