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