Top Description Fields Constructors Methods
io.reactivex.rxjava3.internal.operators.maybe

pack-priv abstract Class AbstractMaybeWithUpstream<T, R>

extends Maybe<R>
implements HasUpstreamMaybeSource<T>
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.internal.fuseable.HasUpstreamMaybeSource
Known Direct Subclasses
io.reactivex.rxjava3.internal.operators.maybe.MaybeDelay, io.reactivex.rxjava3.internal.operators.maybe.MaybeDelayOtherPublisher, io.reactivex.rxjava3.internal.operators.maybe.MaybeDelaySubscriptionOtherPublisher, io.reactivex.rxjava3.internal.operators.maybe.MaybeDematerialize, io.reactivex.rxjava3.internal.operators.maybe.MaybeDetach, io.reactivex.rxjava3.internal.operators.maybe.MaybeDoAfterSuccess, io.reactivex.rxjava3.internal.operators.maybe.MaybeDoFinally, io.reactivex.rxjava3.internal.operators.maybe.MaybeDoOnEvent, io.reactivex.rxjava3.internal.operators.maybe.MaybeDoOnLifecycle, io.reactivex.rxjava3.internal.operators.maybe.MaybeHide, io.reactivex.rxjava3.internal.operators.maybe.MaybeIgnoreElement, io.reactivex.rxjava3.internal.operators.maybe.MaybeIsEmpty, io.reactivex.rxjava3.internal.operators.maybe.MaybeLift, io.reactivex.rxjava3.internal.operators.maybe.MaybeMap, io.reactivex.rxjava3.internal.operators.maybe.MaybeObserveOn, io.reactivex.rxjava3.internal.operators.maybe.MaybeOnErrorComplete, io.reactivex.rxjava3.internal.operators.maybe.MaybeOnErrorNext, io.reactivex.rxjava3.internal.operators.maybe.MaybeOnErrorReturn, io.reactivex.rxjava3.internal.operators.maybe.MaybePeek, io.reactivex.rxjava3.internal.operators.maybe.MaybeSubscribeOn, io.reactivex.rxjava3.internal.operators.maybe.MaybeFilter, io.reactivex.rxjava3.internal.operators.maybe.MaybeFlatMapBiSelector, io.reactivex.rxjava3.internal.operators.maybe.MaybeFlatMapNotification, io.reactivex.rxjava3.internal.operators.maybe.MaybeFlatten, io.reactivex.rxjava3.internal.operators.maybe.MaybeTakeUntilMaybe, io.reactivex.rxjava3.internal.operators.maybe.MaybeTakeUntilPublisher, io.reactivex.rxjava3.internal.operators.maybe.MaybeTimeoutMaybe, io.reactivex.rxjava3.internal.operators.maybe.MaybeTimeoutPublisher, io.reactivex.rxjava3.internal.operators.maybe.MaybeUnsafeCreate, io.reactivex.rxjava3.internal.operators.maybe.MaybeUnsubscribeOn, io.reactivex.rxjava3.internal.operators.maybe.MaybeSwitchIfEmpty
Type Parameters
<T>
the source value type
<R>
the output value type
Imports
io.reactivex.rxjava3.core.*, io.reactivex.rxjava3.internal.fuseable.HasUpstreamMaybeSource
Abstract base class for intermediate Maybe operators that take an upstream MaybeSource.

Field Summary

Modifier and TypeField and Description
protected final MaybeSource<T>
source

Constructor Summary

AccessConstructor and Description
pack-priv
AbstractMaybeWithUpstream(MaybeSource<T> source)

Method Summary

Modifier and TypeMethod and Description
public final MaybeSource<T>
source()

Implements io.reactivex.rxjava3.internal.fuseable.HasUpstreamMaybeSource.source.

Returns the upstream source of this Maybe.
Inherited from io.reactivex.rxjava3.core.Maybe:
ambambArrayambWithblockingGetblockingGetblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribeblockingSubscribecachecastcomposeconcatconcatconcatconcatconcatconcatconcatArrayconcatArrayDelayErrorconcatArrayEagerconcatArrayEagerDelayErrorconcatDelayErrorconcatDelayErrorconcatDelayErrorconcatEagerconcatEagerconcatEagerconcatEagerconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatEagerDelayErrorconcatMapconcatMapCompletableconcatMapSingleconcatWithcontainscountcreatedefaultIfEmptydeferdelaydelaydelaydelaydelaydelaySubscriptiondelaySubscriptiondelaySubscriptiondematerializedoAfterSuccessdoAfterTerminatedoFinallydoOnCompletedoOnDisposedoOnErrordoOnEventdoOnLifecycledoOnSubscribedoOnSuccessdoOnTerminateemptyerrorerrorfilterflatMapflatMapflatMapflatMapCompletableflatMapObservableflatMapPublisherflatMapSingleflattenAsFlowableflattenAsObservableflattenStreamAsFlowableflattenStreamAsObservablefromActionfromCallablefromCompletablefromCompletionStagefromFuturefromFuturefromObservablefromOptionalfromPublisherfromRunnablefromSinglefromSupplierhideignoreElementisEmptyjustliftmapmapOptionalmaterializemergemergemergemergemergemergemergemergeArraymergeArrayDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeDelayErrormergeWithneverobserveOnofTypeonErrorCompleteonErrorCompleteonErrorResumeNextonErrorResumeWithonErrorReturnonErrorReturnItemonTerminateDetachrepeatrepeatrepeatUntilrepeatWhenretryretryretryretryretryretryUntilretryWhensafeSubscribesequenceEqualsequenceEqualstartWithstartWithstartWithstartWithstartWithsubscribesubscribesubscribesubscribesubscribesubscribesubscribeActualsubscribeOnsubscribeWithswitchIfEmptyswitchIfEmptyswitchOnNextswitchOnNextDelayErrortakeUntiltakeUntiltesttesttimeIntervaltimeIntervaltimeIntervaltimeIntervaltimeouttimeouttimeouttimeouttimeouttimeouttimeouttimeouttimertimertimestamptimestamptimestamptimestamptotoCompletionStagetoCompletionStagetoFlowabletoFuturetoObservabletoSingleunsafeCreateunsubscribeOnusingusingwrapzipzipzipzipzipzipzipzipzipzipArrayzipWith

Field Detail

sourceback to summary
protected final MaybeSource<T> source

Constructor Detail

AbstractMaybeWithUpstreamback to summary
pack-priv AbstractMaybeWithUpstream(MaybeSource<T> source)

Method Detail

sourceback to summary
public final MaybeSource<T> source()

Implements io.reactivex.rxjava3.internal.fuseable.HasUpstreamMaybeSource.source.

Doc from io.reactivex.rxjava3.internal.fuseable.HasUpstreamMaybeSource.source.

Returns the upstream source of this Maybe.

Allows discovering the chain of observables.

Returns:MaybeSource<T>

the source MaybeSource

Annotations
@Override