Package io.reactivex.rxjava3.internal.fuseable

Interface HasUpstreamObservableSource<T>

Type Parameters:

T - the value type

All Known Implementing Classes:

AbstractObservableWithUpstream, 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, ObservablePublish, ObservablePublishSelector, ObservableRepeat, ObservableRepeatUntil, ObservableRepeatWhen, ObservableReplay, 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

public interface HasUpstreamObservableSource<@NonNull T>

Interface indicating the implementor has an upstream ObservableSource-like source available via source() method.

Method Summary

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

Method Detail

source

@NonNull
@NonNull ObservableSource<T> source()

Returns the upstream source of this Observable.

Allows discovering the chain of observables.

Returns:

the source ObservableSource