Uses of Interface
io.reactivex.rxjava3.internal.fuseable.HasUpstreamObservableSource

Packages that use HasUpstreamObservableSource

Package	Description
io.reactivex.rxjava3.internal.operators.observable

Uses of HasUpstreamObservableSource in io.reactivex.rxjava3.internal.operators.observable

Classes in io.reactivex.rxjava3.internal.operators.observable that implement HasUpstreamObservableSource

Modifier and Type	Class	Description
(package private) class	AbstractObservableWithUpstream<T,U>	Base class for operators with a source consumable.
final class	ObservableAll<T>
final class	ObservableAny<T>
final class	ObservableBuffer<T, U extends Collection<? super T>>
final class	ObservableBufferBoundary<T, U extends Collection<? super T>, Open, Close>
final class	ObservableBufferExactBoundary<T, U extends Collection<? super T>, B>
final class	ObservableBufferTimed<T, U extends Collection<? super T>>
final class	ObservableCache<T>	An observable which auto-connects to another observable, caches the elements from that observable but allows terminating the connection and completing the cache.
final class	ObservableCollect<T,U>
final class	ObservableConcatMap<T,U>
final class	ObservableConcatMapEager<T,R>
final class	ObservableConcatMapScheduler<T,U>
final class	ObservableConcatWithCompletable<T>	Subscribe to a main Observable first, then when it completes normally, subscribe to a Single, signal its success value followed by a completion or signal its error as is.
final class	ObservableConcatWithMaybe<T>	Subscribe to a main Observable first, then when it completes normally, subscribe to a Maybe, signal its success value followed by a completion or signal its error or completion signal as is.
final class	ObservableConcatWithSingle<T>	Subscribe to a main Observable first, then when it completes normally, subscribe to a Single, signal its success value followed by a completion or signal its error as is.
final class	ObservableCount<T>
final class	ObservableDebounce<T,U>
final class	ObservableDebounceTimed<T>
final class	ObservableDelay<T>
final class	ObservableDematerialize<T,R>
final class	ObservableDetach<T>	Breaks the links between the upstream and the downstream (the Disposable and the Observer references) when the sequence terminates or gets disposed.
final class	ObservableDistinct<T,K>
final class	ObservableDistinctUntilChanged<T,K>
final class	ObservableDoAfterNext<T>	Calls a consumer after pushing the current item to the downstream.
final class	ObservableDoFinally<T>	Execute an action after an onError, onComplete or a dispose event.
final class	ObservableDoOnEach<T>
final class	ObservableDoOnLifecycle<T>
final class	ObservableElementAt<T>
final class	ObservableFilter<T>
final class	ObservableFlatMap<T,U>
final class	ObservableFlatMapCompletable<T>	Maps a sequence of values into CompletableSources and awaits their termination.
final class	ObservableFlatMapMaybe<T,R>	Maps upstream values into MaybeSources and merges their signals into one sequence.
final class	ObservableFlatMapSingle<T,R>	Maps upstream values into SingleSources and merges their signals into one sequence.
final class	ObservableFlattenIterable<T,R>	Maps a sequence into an Iterable and emits its values.
final class	ObservableGroupBy<T,K,V>
final class	ObservableGroupJoin<TLeft, TRight, TLeftEnd, TRightEnd, R>
final class	ObservableHide<T>	Hides the identity of the wrapped ObservableSource and its Disposable.
final class	ObservableIgnoreElements<T>
final class	ObservableJoin<TLeft, TRight, TLeftEnd, TRightEnd, R>
final class	ObservableLift<R,T>	Allows lifting operators into a chain of Observables.
final class	ObservableMap<T,U>
final class	ObservableMapNotification<T,R>
final class	ObservableMaterialize<T>
final class	ObservableMergeWithCompletable<T>	Merges an Observable and a Completable by emitting the items of the Observable and waiting until both the Observable and Completable complete normally.
final class	ObservableMergeWithMaybe<T>	Merges an Observable and a Maybe by emitting the items of the Observable and the success value of the Maybe and waiting until both the Observable and Maybe terminate normally.
final class	ObservableMergeWithSingle<T>	Merges an Observable and a Single by emitting the items of the Observable and the success value of the Single and waiting until both the Observable and Single terminate normally.
final class	ObservableObserveOn<T>
final class	ObservableOnErrorComplete<T>	Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.
final class	ObservableOnErrorNext<T>
final class	ObservableOnErrorReturn<T>
final class	ObservablePublish<T>	Shares a single underlying connection to the upstream ObservableSource and multicasts events to all subscribed observers until the upstream completes or the connection is disposed.
final class	ObservablePublishSelector<T,R>	Shares a source Observable for the duration of a selector function.
final class	ObservableRepeat<T>
final class	ObservableRepeatUntil<T>
final class	ObservableRepeatWhen<T>	Repeatedly subscribe to a source if a handler ObservableSource signals an item.
final class	ObservableReplay<T>
final class	ObservableRetryBiPredicate<T>
final class	ObservableRetryPredicate<T>
final class	ObservableRetryWhen<T>	Repeatedly subscribe to a source if a handler ObservableSource signals an item.
final class	ObservableSampleTimed<T>
final class	ObservableSampleWithObservable<T>
final class	ObservableScan<T>
final class	ObservableScanSeed<T,R>
final class	ObservableSerialized<T>
final class	ObservableSkip<T>
final class	ObservableSkipLast<T>
final class	ObservableSkipLastTimed<T>
final class	ObservableSkipUntil<T,U>
final class	ObservableSkipWhile<T>
final class	ObservableSubscribeOn<T>
final class	ObservableSwitchIfEmpty<T>
final class	ObservableSwitchMap<T,R>
final class	ObservableTake<T>
final class	ObservableTakeLast<T>
final class	ObservableTakeLastOne<T>
final class	ObservableTakeLastTimed<T>
final class	ObservableTakeUntil<T,U>
final class	ObservableTakeUntilPredicate<T>
final class	ObservableTakeWhile<T>
final class	ObservableThrottleFirstTimed<T>
final class	ObservableThrottleLatest<T>	Emits the next or latest item when the given time elapses.
final class	ObservableTimeInterval<T>
final class	ObservableTimeout<T,U,V>
final class	ObservableTimeoutTimed<T>
final class	ObservableToList<T, U extends Collection<? super T>>
final class	ObservableUnsubscribeOn<T>
final class	ObservableWindow<T>
final class	ObservableWindowBoundary<T,B>
final class	ObservableWindowBoundarySelector<T,B,V>
final class	ObservableWindowTimed<T>
final class	ObservableWithLatestFrom<T,U,R>
final class	ObservableWithLatestFromMany<T,R>	Combines a main sequence of values with the latest from multiple other sequences via a selector function.