Uses of Interface
io.reactivex.rxjava3.internal.fuseable.HasUpstreamObservableSource
Packages that use HasUpstreamObservableSource
-
Uses of HasUpstreamObservableSource in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement HasUpstreamObservableSourceModifier and TypeClassDescription(package private) class
Base class for operators with a source consumable.final class
final class
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
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
final class
final class
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
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
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
final class
ObservableDebounce<T,
U> final class
final class
final class
final class
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
final class
Calls a consumer after pushing the current item to the downstream.final class
Execute an action after an onError, onComplete or a dispose event.final class
final class
final class
final class
final class
ObservableFlatMap<T,
U> final class
Maps a sequence of values into CompletableSources and awaits their termination.final class
Maps upstream values into MaybeSources and merges their signals into one sequence.final class
Maps upstream values into SingleSources and merges their signals into one sequence.final class
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
Hides the identity of the wrapped ObservableSource and its Disposable.final class
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
final class
final class
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
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
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
final class
Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.final class
final class
final class
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
Shares a source Observable for the duration of a selector function.final class
final class
final class
Repeatedly subscribe to a source if a handler ObservableSource signals an item.final class
final class
final class
final class
Repeatedly subscribe to a source if a handler ObservableSource signals an item.final class
final class
final class
final class
ObservableScanSeed<T,
R> final class
final class
final class
final class
final class
ObservableSkipUntil<T,
U> final class
final class
final class
final class
ObservableSwitchMap<T,
R> final class
final class
final class
final class
final class
ObservableTakeUntil<T,
U> final class
final class
final class
final class
Emits the next or latest item when the given time elapses.final class
final class
ObservableTimeout<T,
U, V> final class
final class
ObservableToList<T,
U extends Collection<? super T>> final class
final class
final class
final class
final class
final class
ObservableWithLatestFrom<T,
U, R> final class
Combines a main sequence of values with the latest from multiple other sequences via a selector function.