Class AbstractObservableWithUpstream<T,U>
- java.lang.Object
-
- io.reactivex.rxjava3.core.Observable<U>
-
- io.reactivex.rxjava3.internal.operators.observable.AbstractObservableWithUpstream<T,U>
-
- Type Parameters:
T
- the input source typeU
- the output type
- All Implemented Interfaces:
ObservableSource<U>
,HasUpstreamObservableSource<T>
- Direct Known Subclasses:
ObservableAll
,ObservableAny
,ObservableBuffer
,ObservableBufferBoundary
,ObservableBufferExactBoundary
,ObservableBufferTimed
,ObservableCache
,ObservableCollect
,ObservableConcatMap
,ObservableConcatMapEager
,ObservableConcatMapScheduler
,ObservableConcatWithCompletable
,ObservableConcatWithMaybe
,ObservableConcatWithSingle
,ObservableCount
,ObservableDebounce
,ObservableDebounceTimed
,ObservableDelay
,ObservableDematerialize
,ObservableDetach
,ObservableDistinct
,ObservableDistinctUntilChanged
,ObservableDoAfterNext
,ObservableDoFinally
,ObservableDoOnEach
,ObservableDoOnLifecycle
,ObservableElementAt
,ObservableFilter
,ObservableFlatMap
,ObservableFlatMapCompletable
,ObservableFlatMapMaybe
,ObservableFlatMapSingle
,ObservableFlattenIterable
,ObservableGroupBy
,ObservableGroupJoin
,ObservableHide
,ObservableIgnoreElements
,ObservableJoin
,ObservableLift
,ObservableMap
,ObservableMapNotification
,ObservableMaterialize
,ObservableMergeWithCompletable
,ObservableMergeWithMaybe
,ObservableMergeWithSingle
,ObservableObserveOn
,ObservableOnErrorComplete
,ObservableOnErrorNext
,ObservableOnErrorReturn
,ObservablePublishSelector
,ObservableRepeat
,ObservableRepeatUntil
,ObservableRepeatWhen
,ObservableRetryBiPredicate
,ObservableRetryPredicate
,ObservableRetryWhen
,ObservableSampleTimed
,ObservableSampleWithObservable
,ObservableScan
,ObservableScanSeed
,ObservableSerialized
,ObservableSkip
,ObservableSkipLast
,ObservableSkipLastTimed
,ObservableSkipUntil
,ObservableSkipWhile
,ObservableSubscribeOn
,ObservableSwitchIfEmpty
,ObservableSwitchMap
,ObservableTake
,ObservableTakeLast
,ObservableTakeLastOne
,ObservableTakeLastTimed
,ObservableTakeUntil
,ObservableTakeUntilPredicate
,ObservableTakeWhile
,ObservableThrottleFirstTimed
,ObservableThrottleLatest
,ObservableTimeInterval
,ObservableTimeout
,ObservableTimeoutTimed
,ObservableToList
,ObservableUnsubscribeOn
,ObservableWindow
,ObservableWindowBoundary
,ObservableWindowBoundarySelector
,ObservableWindowTimed
,ObservableWithLatestFrom
,ObservableWithLatestFromMany
abstract class AbstractObservableWithUpstream<T,U> extends Observable<U> implements HasUpstreamObservableSource<T>
Base class for operators with a source consumable.
-
-
Field Summary
Fields Modifier and Type Field Description protected ObservableSource<T>
source
The source consumable Observable.
-
Constructor Summary
Constructors Constructor Description AbstractObservableWithUpstream(ObservableSource<T> source)
Constructs the ObservableSource with the given consumable.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ObservableSource<T>
source()
Returns the upstream source of this Observable.-
Methods inherited from class io.reactivex.rxjava3.core.Observable
all, amb, ambArray, ambWith, any, blockingFirst, blockingFirst, blockingForEach, blockingForEach, blockingIterable, blockingIterable, blockingLast, blockingLast, blockingLatest, blockingMostRecent, blockingNext, blockingSingle, blockingSingle, blockingStream, blockingStream, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, blockingSubscribe, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, buffer, bufferSize, cache, cacheWithInitialCapacity, cast, collect, collect, collectInto, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatestArray, combineLatestArray, combineLatestArrayDelayError, combineLatestArrayDelayError, combineLatestDelayError, combineLatestDelayError, compose, concat, concat, concat, concat, concat, concat, concatArray, concatArrayDelayError, concatArrayEager, concatArrayEager, concatArrayEagerDelayError, concatArrayEagerDelayError, concatDelayError, concatDelayError, concatDelayError, concatEager, concatEager, concatEager, concatEager, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatEagerDelayError, concatMap, concatMap, concatMap, concatMapCompletable, concatMapCompletable, concatMapCompletableDelayError, concatMapCompletableDelayError, concatMapCompletableDelayError, concatMapDelayError, concatMapDelayError, concatMapDelayError, concatMapEager, concatMapEager, concatMapEagerDelayError, concatMapEagerDelayError, concatMapIterable, concatMapMaybe, concatMapMaybe, concatMapMaybeDelayError, concatMapMaybeDelayError, concatMapMaybeDelayError, concatMapSingle, concatMapSingle, concatMapSingleDelayError, concatMapSingleDelayError, concatMapSingleDelayError, concatMapStream, concatWith, concatWith, concatWith, concatWith, contains, count, create, debounce, debounce, debounce, debounce, defaultIfEmpty, defer, delay, delay, delay, delay, delay, delay, delaySubscription, delaySubscription, delaySubscription, dematerialize, distinct, distinct, distinct, distinctUntilChanged, distinctUntilChanged, distinctUntilChanged, doAfterNext, doAfterTerminate, doFinally, doOnComplete, doOnDispose, doOnEach, doOnEach, doOnError, doOnLifecycle, doOnNext, doOnSubscribe, doOnTerminate, elementAt, elementAt, elementAtOrError, empty, error, error, filter, first, firstElement, firstOrError, firstOrErrorStage, firstStage, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMap, flatMapCompletable, flatMapCompletable, flatMapIterable, flatMapIterable, flatMapMaybe, flatMapMaybe, flatMapSingle, flatMapSingle, flatMapStream, forEach, forEachWhile, forEachWhile, forEachWhile, fromAction, fromArray, fromCallable, fromCompletable, fromCompletionStage, fromFuture, fromFuture, fromIterable, fromMaybe, fromOptional, fromPublisher, fromRunnable, fromSingle, fromStream, fromSupplier, generate, generate, generate, generate, generate, groupBy, groupBy, groupBy, groupBy, groupBy, groupJoin, hide, ignoreElements, interval, interval, interval, interval, intervalRange, intervalRange, isEmpty, join, just, just, just, just, just, just, just, just, just, just, last, lastElement, lastOrError, lastOrErrorStage, lastStage, lift, map, mapOptional, materialize, merge, merge, merge, merge, merge, merge, merge, merge, mergeArray, mergeArray, mergeArrayDelayError, mergeArrayDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeDelayError, mergeWith, mergeWith, mergeWith, mergeWith, never, observeOn, observeOn, observeOn, ofType, onErrorComplete, onErrorComplete, onErrorResumeNext, onErrorResumeWith, onErrorReturn, onErrorReturnItem, onTerminateDetach, publish, publish, range, rangeLong, reduce, reduce, reduceWith, repeat, repeat, repeatUntil, repeatWhen, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, replay, retry, retry, retry, retry, retry, retryUntil, retryWhen, safeSubscribe, sample, sample, sample, sample, sample, sample, sample, scan, scan, scanWith, sequenceEqual, sequenceEqual, sequenceEqual, sequenceEqual, serialize, share, single, singleElement, singleOrError, singleOrErrorStage, singleStage, skip, skip, skip, skipLast, skipLast, skipLast, skipLast, skipLast, skipLast, skipUntil, skipWhile, sorted, sorted, startWith, startWith, startWith, startWith, startWithArray, startWithItem, startWithIterable, subscribe, subscribe, subscribe, subscribe, subscribe, subscribe, subscribeActual, subscribeOn, subscribeWith, switchIfEmpty, switchMap, switchMap, switchMapCompletable, switchMapCompletableDelayError, switchMapDelayError, switchMapDelayError, switchMapMaybe, switchMapMaybeDelayError, switchMapSingle, switchMapSingleDelayError, switchOnNext, switchOnNext, switchOnNextDelayError, switchOnNextDelayError, take, take, take, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeLast, takeUntil, takeUntil, takeWhile, test, test, throttleFirst, throttleFirst, throttleFirst, throttleLast, throttleLast, throttleLast, throttleLatest, throttleLatest, throttleLatest, throttleLatest, throttleLatest, throttleWithTimeout, throttleWithTimeout, throttleWithTimeout, timeInterval, timeInterval, timeInterval, timeInterval, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timeout, timer, timer, timestamp, timestamp, timestamp, timestamp, to, toFlowable, toFuture, toList, toList, toList, toMap, toMap, toMap, toMultimap, toMultimap, toMultimap, toMultimap, toSortedList, toSortedList, toSortedList, toSortedList, unsafeCreate, unsubscribeOn, using, using, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, window, withLatestFrom, withLatestFrom, withLatestFrom, withLatestFrom, withLatestFrom, withLatestFrom, wrap, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zip, zipArray, zipWith, zipWith, zipWith, zipWith
-
-
-
-
Field Detail
-
source
protected final ObservableSource<T> source
The source consumable Observable.
-
-
Constructor Detail
-
AbstractObservableWithUpstream
AbstractObservableWithUpstream(ObservableSource<T> source)
Constructs the ObservableSource with the given consumable.- Parameters:
source
- the consumable Observable
-
-
Method Detail
-
source
public final ObservableSource<T> source()
Description copied from interface:HasUpstreamObservableSource
Returns the upstream source of this Observable.Allows discovering the chain of observables.
- Specified by:
source
in interfaceHasUpstreamObservableSource<T>
- Returns:
- the source ObservableSource
-
-