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 type

U - 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 final 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

Modifier and Type	Method	Description
final ObservableSource<T>	source()	Returns the upstream source of this Observable.

Methods inherited from class 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

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

source

protected final ObservableSource<T> source

The source consumable Observable.

Constructor Details

AbstractObservableWithUpstream

AbstractObservableWithUpstream(ObservableSource<T> source)

Constructs the ObservableSource with the given consumable.

Parameters:

source - the consumable Observable

Method Details

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 interface HasUpstreamObservableSource<T>

Returns:

the source ObservableSource