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 class AbstractMaybeWithUpstream<T,R> extends Maybe<R> implements HasUpstreamMaybeSource<T>
Abstract base class for intermediate Maybe operators that take an upstream MaybeSource.
-
-
Field Summary
Fields Modifier and Type Field Description protected MaybeSource<T>
source
-
Constructor Summary
Constructors Constructor Description AbstractMaybeWithUpstream(MaybeSource<T> source)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description 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 Detail
-
source
protected final MaybeSource<T> source
-
-
Constructor Detail
-
AbstractMaybeWithUpstream
AbstractMaybeWithUpstream(MaybeSource<T> source)
-
-
Method Detail
-
source
public final MaybeSource<T> 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
-
-