Class AbstractMaybeWithUpstream<T,R>
java.lang.Object
io.reactivex.rxjava3.core.Maybe<R>
io.reactivex.rxjava3.internal.operators.maybe.AbstractMaybeWithUpstream<T,R>
- Type Parameters:
T
- the source value typeR
- the output value type
- All Implemented Interfaces:
MaybeSource<R>
,HasUpstreamMaybeSource<T>
- Direct Known Subclasses:
MaybeDelay
,MaybeDelayOtherPublisher
,MaybeDelaySubscriptionOtherPublisher
,MaybeDematerialize
,MaybeDetach
,MaybeDoAfterSuccess
,MaybeDoFinally
,MaybeDoOnEvent
,MaybeDoOnLifecycle
,MaybeFilter
,MaybeFlatMapBiSelector
,MaybeFlatMapNotification
,MaybeFlatten
,MaybeHide
,MaybeIgnoreElement
,MaybeIsEmpty
,MaybeLift
,MaybeMap
,MaybeObserveOn
,MaybeOnErrorComplete
,MaybeOnErrorNext
,MaybeOnErrorReturn
,MaybePeek
,MaybeSubscribeOn
,MaybeSwitchIfEmpty
,MaybeTakeUntilMaybe
,MaybeTakeUntilPublisher
,MaybeTimeoutMaybe
,MaybeTimeoutPublisher
,MaybeUnsafeCreate
,MaybeUnsubscribeOn
Abstract base class for intermediate Maybe operators that take an upstream MaybeSource.
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionfinal MaybeSource
<T> source()
Returns the upstream source of this Maybe.Methods inherited from class io.reactivex.rxjava3.core.Maybe
amb, ambArray, ambWith, blockingGet, blockingGet, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, cache, cast, compose, concat, concat, concat, concat, concat, concat, concatArray, concatArrayDelayError, concatArrayEager, concatArrayEagerDelayError, concatDelayError, concatDelayError, concatDelayError, concatEager, concatEager, concatEager, concatEager, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatMap, concatMapCompletable, concatMapSingle, concatWith, contains, count, create, defaultIfEmpty, defer, delay, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, dematerialize, doAfterSuccess, doAfterTerminate, doFinally, doOnComplete, doOnDispose, doOnError, doOnEvent, doOnLifecycle, doOnSubscribe, doOnSuccess, doOnTerminate, empty, error, error, filter, flatMap, flatMap, flatMap, flatMapCompletable, flatMapObservable, flatMapPublisher, flatMapSingle, flattenAsFlowable, flattenAsObservable, flattenStreamAsFlowable, flattenStreamAsObservable, fromAction, fromCallable, fromCompletable, fromCompletionStage, fromFuture, fromFuture, fromObservable, fromOptional, fromPublisher, fromRunnable, fromSingle, fromSupplier, hide, ignoreElement, isEmpty, just, lift, map, mapOptional, materialize, merge, merge, merge, merge, merge, merge, merge, mergeArray, mergeArrayDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, never, observeOn, ofType, onErrorComplete, onErrorComplete, onErrorResumeNext, onErrorResumeWith, onErrorReturn, onErrorReturnItem, onTerminateDetach, repeat, repeat, repeatUntil, repeatWhen, retry, retry, retry, retry, retry, retryUntil, retryWhen, safeSubscribe, sequenceEqual, sequenceEqual, startWith, startWith, startWith, startWith, startWith, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeActual, subscribeOn, subscribeWith, switchIfEmpty, switchIfEmpty, switchOnNext, switchOnNextDelayError, takeUntil, takeUntil, test, test, timeInterval, timeInterval, timeInterval, timeInterval, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, timestamp, timestamp, timestamp, timestamp, to, toCompletionStage, toCompletionStage, toFlowable, toFuture, toObservable, toSingle, unsafeCreate, unsubscribeOn, using, using, wrap, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipArray, zipWith
-
Field Details
-
source
-
-
Constructor Details
-
AbstractMaybeWithUpstream
AbstractMaybeWithUpstream(MaybeSource<T> source)
-
-
Method Details
-
source
Description copied from interface:HasUpstreamMaybeSource
Returns the upstream source of this Maybe.Allows discovering the chain of observables.
- Specified by:
source
in interfaceHasUpstreamMaybeSource<T>
- Returns:
- the source MaybeSource
-