Package io.reactivex.rxjava3.internal.operators.observable
package io.reactivex.rxjava3.internal.operators.observable
-
ClassDescriptionBase class for operators with a source consumable.Wait for and iterate over the latest values of the source observable.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.Wraps a ConnectableObservable and calls its connect() method once the specified number of Observers have subscribed.Utility methods to consume an Observable in a blocking manner with callbacks or Observer.ObservableBuffer<T,
U extends Collection<? super T>> ObservableBuffer.BufferExactObserver<T,U extends Collection<? super T>> ObservableBuffer.BufferSkipObserver<T,U extends Collection<? super T>> ObservableBufferBoundary<T,U extends Collection<? super T>, Open, Close> ObservableBufferBoundary.BufferBoundaryObserver<T,C extends Collection<? super T>, Open, Close> ObservableBufferBoundary.BufferCloseObserver<T,C extends Collection<? super T>> ObservableBufferExactBoundary<T,U extends Collection<? super T>, B> ObservableBufferExactBoundary.BufferBoundaryObserver<T,U extends Collection<? super T>, B> ObservableBufferExactBoundary.BufferExactBoundaryObserver<T,U extends Collection<? super T>, B> ObservableBufferTimed<T,U extends Collection<? super T>> ObservableBufferTimed.BufferExactBoundedObserver<T,U extends Collection<? super T>> ObservableBufferTimed.BufferExactUnboundedObserver<T,U extends Collection<? super T>> ObservableBufferTimed.BufferSkipBoundedObserver<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.ObservableCollect<T,U> ObservableConcatMap<T,U> 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.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.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.Serializes calls to onNext, onError and onComplete.ObservableDebounce<T,U> Delays the subscription to the main source until the other observable fires an event or completes.Breaks the links between the upstream and the downstream (the Disposable and the Observer references) when the sequence terminates or gets disposed.ObservableDistinct<T,K> Calls a consumer after pushing the current item to the downstream.Execute an action after an onError, onComplete or a dispose event.ObservableFlatMap<T,U> Maps a sequence of values into CompletableSources and awaits their termination.Maps a sequence of values into CompletableSources and awaits their termination.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 a sequence into an Iterable and emits its values.Executes anAction
and signals its exception or completes normally.Calls a Callable and emits its resulting single value or signals its exception.Wrap a Completable into an Observable.Executes anRunnable
and signals its exception or completes normally.Calls a Supplier and emits its resulting single value or signals its exception.ObservableGenerate<T,S> ObservableGroupBy<T,K, V> ObservableGroupJoin<TLeft,TRight, TLeftEnd, TRightEnd, R> ObservableGroupJoin.GroupJoinDisposable<TLeft,TRight, TLeftEnd, TRightEnd, R> Hides the identity of the wrapped ObservableSource and its Disposable.Helper utility class to support Observable with inner classes.ObservableJoin<TLeft,TRight, TLeftEnd, TRightEnd, R> ObservableJoin.JoinDisposable<TLeft,TRight, TLeftEnd, TRightEnd, R> Represents a constant scalar value.Consumes the source ObservableSource and emits its last item, the defaultItem if empty or a NoSuchElementException if even the defaultItem is null.Consumes the source ObservableSource and emits its last item, the defaultItem if empty or a NoSuchElementException if even the defaultItem is null.ObservableLift<R,T> Allows lifting operators into a chain of Observables.ObservableMap<T,U> Merges an Observable and a Completable by emitting the items of the Observable and waiting until both the Observable 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 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.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 ObservableSource and multicasts events to all subscribed observers until the upstream completes or the connection is disposed.Intercepts the dispose signal from the downstream and removes itself from the connection's observers array at most once.Shares a source Observable for the duration of a selector function.Emits a range of integer values from start to end.Reduce a sequence of values into a single value via an aggregator function and emit the final value or complete if the source is empty.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.Repeatedly subscribe to a source if a handler ObservableSource signals an item.Base class for bounded buffering with options to specify an enter and leave transforms and custom truncation behavior.A Disposable that manages the disposed state of a child Observer 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.Repeatedly subscribe to a source if a handler ObservableSource signals an item.Utility classes to work with scalar-sourced XMap operators (where X == { flat, concat, switch }).Represents a Disposable that signals one onNext followed by an onComplete.Maps a scalar value to an ObservableSource and subscribes to it.ObservableScanSeed<T,R> ObservableSkipUntil<T,U> ObservableSwitchMap<T,R> ObservableTakeUntil<T,U> Emits the next or latest item when the given time elapses.ObservableTimeout<T,U, V> ObservableToList<T,U extends Collection<? super T>> ObservableToList.ToListObserver<T,U extends Collection<? super T>> ObservableToListSingle<T,U extends Collection<? super T>> ObservableToListSingle.ToListObserver<T,U extends Collection<? super T>> ObservableUsing<T,D> Wrapper for a Subject that detects an incoming subscriber.ObservableWithLatestFrom<T,U, R> Combines a main sequence of values with the latest from multiple other sequences via a selector function.ObservableZip<T,R> ObservableZipIterable<T,U, V>