Uses of Interface
io.reactivex.rxjava3.internal.fuseable.HasUpstreamPublisher
Packages that use HasUpstreamPublisher
-
Uses of HasUpstreamPublisher in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement HasUpstreamPublisherModifier and TypeClassDescription(package private) class
Abstract base class for operators that take an upstream sourcePublisher
.final class
FlowableAll<T>
final class
FlowableAny<T>
final class
FlowableBuffer<T,
C extends Collection<? super T>> final class
FlowableBufferBoundary<T,
U extends Collection<? super T>, Open, Close> final class
FlowableBufferExactBoundary<T,
U extends Collection<? super T>, B> final class
FlowableBufferTimed<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
FlowableCollect<T,
U> final class
FlowableConcatMap<T,
R> final class
final class
final class
Subscribe to a main Flowable first, then when it completes normally, subscribe to a Completable and terminate when it terminates.final class
Subscribe to a main Flowable 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 Flowable 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
FlowableDebounce<T,
U> final class
final class
final class
final class
final class
FlowableDistinct<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 cancel event.final class
final class
final class
final class
final class
FlowableFlatMap<T,
U> final class
Maps a sequence of values into CompletableSources and awaits their termination.final class
FlowableFlatMapMaybe<T,
R> 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
final class
FlowableGroupBy<T,
K, V> final class
FlowableGroupJoin<TLeft,
TRight, TLeftEnd, TRightEnd, R> final class
FlowableHide<T>
Hides the identity of the wrapped Flowable and its Subscription.final class
final class
FlowableJoin<TLeft,
TRight, TLeftEnd, TRightEnd, R> final class
FlowableLift<R,
T> Allows lifting operators into a chain of Publishers.final class
FlowableMap<T,
U> final class
final class
final class
Merges a Flowable and a Completable by emitting the items of the Flowable and waiting until both the Flowable 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 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
final class
final class
Handle backpressure with a bounded buffer and custom strategy.final class
final class
final class
final class
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 Publisher and multicasts events to all subscribed subscribers until the upstream completes or the connection is disposed.final class
Multicasts a Flowable over a selector function.final class
Reduces a sequence via a function into a single value or signals NoSuchElementException for an empty source.final class
Reduce a Flowable into a single value exposed as Single or signal NoSuchElementException.final class
final class
final class
final class
final class
final class
final class
final class
final class
FlowableScan<T>
final class
FlowableScanSeed<T,
R> final class
final class
final class
FlowableSkip<T>
final class
final class
final class
FlowableSkipUntil<T,
U> final class
final class
Subscribes to the source Flowable on the specified Scheduler and makes sure downstream requests are scheduled there as well.final class
final class
FlowableSwitchMap<T,
R> final class
FlowableTake<T>
final class
final class
final class
final class
FlowableTakeUntil<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
FlowableTimeout<T,
U, V> final class
final class
FlowableToList<T,
U extends Collection<? super T>> final class
final class
final class
final class
final class
final class
FlowableWithLatestFrom<T,
U, R> final class
Combines a main sequence of values with the latest from multiple other sequences via a selector function.final class
FlowableZipIterable<T,
U, V>