Package io.reactivex.rxjava3.internal.operators.flowable
package io.reactivex.rxjava3.internal.operators.flowable
-
ClassDescriptionAbstract base class for operators that throttle excessive updates from upstream in case if downstream
Subscriber
is not ready to receive updates.Abstract base class for operators that take an upstream sourcePublisher
.Wait for and iterate over the latest values of the source observable.Subscriber of source, iterator for output.Returns an Iterable that always returns the item most recently emitted by an Observable, or a seed value if no item has yet been emitted.Returns an Iterable that blocks until the Observable emits another item, then returns that item.FlowableAll<T>FlowableAmb<T>FlowableAny<T>Wraps aConnectableFlowable
and calls itsconnect()
method once the specified number ofSubscriber
s have subscribed.Utility methods to consume a Publisher in a blocking manner with callbacks or Subscriber.FlowableBuffer<T,C extends Collection<? super T>> FlowableBuffer.PublisherBufferExactSubscriber<T,C extends Collection<? super T>> FlowableBuffer.PublisherBufferOverlappingSubscriber<T,C extends Collection<? super T>> FlowableBuffer.PublisherBufferSkipSubscriber<T,C extends Collection<? super T>> FlowableBufferBoundary<T,U extends Collection<? super T>, Open, Close> FlowableBufferBoundary.BufferBoundarySubscriber<T,C extends Collection<? super T>, Open, Close> FlowableBufferBoundary.BufferCloseSubscriber<T,C extends Collection<? super T>> FlowableBufferExactBoundary<T,U extends Collection<? super T>, B> FlowableBufferExactBoundary.BufferBoundarySubscriber<T,U extends Collection<? super T>, B> FlowableBufferExactBoundary.BufferExactBoundarySubscriber<T,U extends Collection<? super T>, B> FlowableBufferTimed<T,U extends Collection<? super T>> FlowableBufferTimed.BufferExactBoundedSubscriber<T,U extends Collection<? super T>> FlowableBufferTimed.BufferExactUnboundedSubscriber<T,U extends Collection<? super T>> FlowableBufferTimed.BufferSkipBoundedSubscriber<T,U extends Collection<? super T>> An observable which auto-connects to another observable, caches the elements from that observable but allows terminating the connection and completing the cache.Hosts the downstream consumer and its current requested and replay states.Represents a segment of the cached item list as part of a linked-node-list structure.FlowableCollect<T,U> Combines the latest values from multiple sources through a function.FlowableConcatMap<T,R> ConcatMapEager which works with an arbitrary Publisher source.Subscribe to a main Flowable first, then when it completes normally, subscribe to a Completable and terminate when it terminates.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.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.Serializes calls to onNext, onError and onComplete.FlowableDebounce<T,U> Delays the subscription to the main source until the other observable fires an event or completes.FlowableDistinct<T,K> Calls a consumer after pushing the current item to the downstream.Execute an action after an onError, onComplete or a cancel event.Emits the indexth element from a Publisher as a Maybe.A source Flowable that signals an onSubscribe() + onComplete() only.FlowableFlatMap<T,U> Maps a sequence of values into CompletableSources and awaits their termination.Maps a sequence of values into CompletableSources and awaits their termination.FlowableFlatMapMaybe<T,R> Maps upstream values into MaybeSources and merges their signals into one sequence.Maps upstream values into MaybeSources and merges their signals into one sequence.Maps upstream values into SingleSources and merges their signals into one sequence.Maps upstream values into SingleSources and merges their signals into one sequence.Executes anAction
and signals its exception or completes normally.Wrap a Completable into a Flowable.Executes anRunnable
and signals its exception or completes normally.Call a Supplier for each incoming Subscriber and signal the returned value or the thrown exception.FlowableGenerate<T,S> FlowableGroupBy<T,K, V> FlowableGroupJoin<TLeft,TRight, TLeftEnd, TRightEnd, R> FlowableGroupJoin.GroupJoinSubscription<TLeft,TRight, TLeftEnd, TRightEnd, R> FlowableHide<T>Hides the identity of the wrapped Flowable and its Subscription.Helper utility class to support Flowable with inner classes.FlowableJoin<TLeft,TRight, TLeftEnd, TRightEnd, R> FlowableJoin.JoinSubscription<TLeft,TRight, TLeftEnd, TRightEnd, R> FlowableJust<T>Represents a constant scalar value.Consumes the source Publisher and emits its last item or completes.Consumes the source Publisher and emits its last item or the defaultItem if empty.FlowableLift<R,T> Allows lifting operators into a chain of Publishers.FlowableMap<T,U> FlowableMapPublisher<T,U> Map working with an arbitrary Publisher source.Merges a Flowable and a Completable by emitting the items of the Flowable and waiting until both the Flowable and Completable complete normally.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.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.Handle backpressure with a bounded buffer and custom strategy.Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.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.Multicasts a Flowable over a selector function.Emits a range of integer values.Emits a range of long values.Reduces a sequence via a function into a single value or signals NoSuchElementException for an empty source.Reduce a Flowable into a single value exposed as Single or signal NoSuchElementException.Reduce a sequence of values, starting from a seed value and by using an accumulator function and return the last accumulated value.Reduce a sequence of values, starting from a generated seed value and by using an accumulator function and return the last accumulated value.Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence.Base class for bounded buffering with options to specify an enter and leave transforms and custom truncation behavior.A Subscription that manages the request and cancellation state of a child subscriber in thread-safe manner.Represents a node in a bounded replay buffer's linked list.The interface for interacting with various buffering logic.Size and time bound replay buffer.A bounded replay buffer implementation with size limit only.Holds an unbounded list of events.Utility classes to work with scalar-sourced XMap operators (where X == { flat, concat, switch }).Maps a scalar value to a Publisher and subscribes to it.FlowableScan<T>FlowableScanSeed<T,R> Provides callbacks for the EqualSubscribers.FlowableSkip<T>FlowableSkipUntil<T,U> Subscribes to the source Flowable on the specified Scheduler and makes sure downstream requests are scheduled there as well.FlowableSwitchMap<T,R> FlowableTake<T>Take with a generic Publisher source.FlowableTakeUntil<T,U> Emits the next or latest item when the given time elapses.FlowableTimeout<T,U, V> FlowableToList<T,U extends Collection<? super T>> FlowableToList.ToListSubscriber<T,U extends Collection<? super T>> FlowableToListSingle<T,U extends Collection<? super T>> FlowableToListSingle.ToListSubscriber<T,U extends Collection<? super T>> FlowableUsing<T,D> Wrapper for a FlowableProcessor that detects an incoming subscriber.FlowableWithLatestFrom<T,U, R> Combines a main sequence of values with the latest from multiple other sequences via a selector function.FlowableZip<T,R> FlowableZipIterable<T,U, V>