Top Classes
[default module]

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

Class Summary

Modifier and TypeClass and Description
pack-priv abstract class
AbstractObservableWithUpstream<
the input source type
T,
the output type
U>

Base class for operators with a source consumable.

public class
BlockingObservableIterable<T>

public class
BlockingObservableLatest<
the value type
T>

Wait for and iterate over the latest values of the source observable.

public class
BlockingObservableMostRecent<
the value type
T>

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.

public class
BlockingObservableNext<
the value type
T>

Returns an Iterable that blocks until the Observable emits another item, then returns that item.

public class
ObservableAll<T>

public class
ObservableAllSingle<T>

public class
ObservableAmb<T>

public class
ObservableAny<T>

public class
ObservableAnySingle<T>

public class
ObservableAutoConnect<
the value type of the chain
T>

Wraps a ConnectableObservable and calls its connect() method once the specified number of Observers have subscribed.

public class
ObservableBlockingSubscribe

Utility methods to consume an Observable in a blocking manner with callbacks or Observer.

public class
ObservableBuffer<T, U extends Collection<? super T>>

public class
ObservableBufferBoundary<T, U extends Collection<? super T>, Open, Close>

public class
ObservableBufferExactBoundary<T, U extends Collection<? super T>, B>

public class
ObservableBufferTimed<T, U extends Collection<? super T>>

public class
ObservableCache<
the source element type
T>

An observable which auto-connects to another observable, caches the elements from that observable but allows terminating the connection and completing the cache.

public class
ObservableCollect<T, U>

public class
ObservableCollectSingle<T, U>

public class
ObservableCombineLatest<T, R>

public class
ObservableConcatMap<T, U>

public class
ObservableConcatMapEager<T, R>

public class
ObservableConcatMapScheduler<T, U>

public class
ObservableConcatWithCompletable<
the element type of the main source and output type
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.

public class
ObservableConcatWithMaybe<
the element type of the main source and output type
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.

public class
ObservableConcatWithSingle<
the element type of the main source and output type
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.

public class
ObservableCount<T>

public class
ObservableCountSingle<T>

public class
ObservableCreate<T>

public class
ObservableDebounce<T, U>

public class
ObservableDebounceTimed<T>

public class
ObservableDefer<T>

public class
ObservableDelay<T>

public class
ObservableDelaySubscriptionOther<
the main type
T,
the other value type, ignored
U>

Delays the subscription to the main source until the other observable fires an event or completes.

public class
ObservableDematerialize<T, R>

public class
ObservableDetach<
the value type
T>

Breaks the links between the upstream and the downstream (the Disposable and the Observer references) when the sequence terminates or gets disposed.

public class
ObservableDistinct<T, K>

public class
ObservableDistinctUntilChanged<T, K>

public class
ObservableDoAfterNext<
the value type
T>

Calls a consumer after pushing the current item to the downstream.

public class
ObservableDoFinally<
the value type
T>

Execute an action after an onError, onComplete or a dispose event.

public class
ObservableDoOnEach<T>

public class
ObservableDoOnLifecycle<T>

public class
ObservableElementAt<T>

public class
ObservableElementAtMaybe<T>

public class
ObservableElementAtSingle<T>

public class
ObservableEmpty

public class
ObservableError<T>

public class
ObservableFilter<T>

public class
ObservableFlatMap<T, U>

public class
ObservableFlatMapCompletable<
the value type
T>

Maps a sequence of values into CompletableSources and awaits their termination.

public class
ObservableFlatMapCompletableCompletable<
the value type
T>

Maps a sequence of values into CompletableSources and awaits their termination.

public class
ObservableFlatMapMaybe<
the source value type
T,
the result value type
R>

Maps upstream values into MaybeSources and merges their signals into one sequence.

public class
ObservableFlatMapSingle<
the source value type
T,
the result value type
R>

Maps upstream values into SingleSources and merges their signals into one sequence.

public class
ObservableFlattenIterable<
the input value type to map to Iterable
T,
the element type of the Iterable and the output
R>

Maps a sequence into an Iterable and emits its values.

public class
ObservableFromAction<
the value type
T>

Executes an Action and signals its exception or completes normally.

public class
ObservableFromArray<T>

public class
ObservableFromCallable<
the value type
T>

Calls a Callable and emits its resulting single value or signals its exception.

public class
ObservableFromCompletable<
the value type
T>

Wrap a Completable into an Observable.

public class
ObservableFromFuture<T>

public class
ObservableFromIterable<T>

public class
ObservableFromPublisher<T>

public class
ObservableFromRunnable<
the value type
T>

Executes an Runnable and signals its exception or completes normally.

public class
ObservableFromSupplier<
the value type
T>

Calls a Supplier and emits its resulting single value or signals its exception.

public class
ObservableFromUnsafeSource<T>

public class
ObservableGenerate<T, S>

public class
ObservableGroupBy<T, K, V>

public class
ObservableGroupJoin<TLeft, TRight, TLeftEnd, TRightEnd, R>

public class
ObservableHide<
the value type
T>

Hides the identity of the wrapped ObservableSource and its Disposable.

public class
ObservableIgnoreElements<T>

public class
ObservableIgnoreElementsCompletable<T>

public class
ObservableInternalHelper

Helper utility class to support Observable with inner classes.

public class
ObservableInterval

public class
ObservableIntervalRange

public class
ObservableJoin<TLeft, TRight, TLeftEnd, TRightEnd, R>

public class
ObservableJust<
the value type
T>

Represents a constant scalar value.

public class
ObservableLastMaybe<
the value type
T>

Consumes the source ObservableSource and emits its last item, the defaultItem if empty or a NoSuchElementException if even the defaultItem is null.

public class
ObservableLastSingle<
the value type
T>

Consumes the source ObservableSource and emits its last item, the defaultItem if empty or a NoSuchElementException if even the defaultItem is null.

public class
ObservableLift<
the downstream parameter type
R,
the upstream value type
T>

Allows lifting operators into a chain of Observables.

public class
ObservableMap<T, U>

public class
ObservableMapNotification<T, R>

public class
ObservableMaterialize<T>

public class
ObservableMergeWithCompletable<
the element type of the Observable
T>

Merges an Observable and a Completable by emitting the items of the Observable and waiting until both the Observable and Completable complete normally.

public class
ObservableMergeWithMaybe<
the element type of the Observable
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.

public class
ObservableMergeWithSingle<
the element type of the Observable
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.

public class
ObservableNever

public class
ObservableObserveOn<T>

public class
ObservableOnErrorComplete<
the value type
T>

Emits an onComplete if the source emits an onError and the predicate returns true for that Throwable.

public class
ObservableOnErrorNext<T>

public class
ObservableOnErrorReturn<T>

public class
ObservablePublish<
the element type
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.

public class
ObservablePublishSelector<
the input value type
T,
the output value type
R>

Shares a source Observable for the duration of a selector function.

public class
ObservableRange

Emits a range of integer values from start to end.

public class
ObservableRangeLong

public class
ObservableReduceMaybe<
the source and result value type
T>

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.

public class
ObservableReduceSeedSingle<
the source value type
T,
the accumulated result type
R>

Reduce a sequence of values, starting from a seed value and by using an accumulator function and return the last accumulated value.

public class
ObservableReduceWithSingle<
the source value type
T,
the accumulated result type
R>

Reduce a sequence of values, starting from a generated seed value and by using an accumulator function and return the last accumulated value.

public class
ObservableRefCount<
the value type
T>

Returns an observable sequence that stays connected to the source as long as there is at least one subscription to the observable sequence.

public class
ObservableRepeat<T>

public class
ObservableRepeatUntil<T>

public class
ObservableRepeatWhen<
the value type
T>

Repeatedly subscribe to a source if a handler ObservableSource signals an item.

public class
ObservableReplay<T>

public class
ObservableRetryBiPredicate<T>

public class
ObservableRetryPredicate<T>

public class
ObservableRetryWhen<
the value type
T>

Repeatedly subscribe to a source if a handler ObservableSource signals an item.

public class
ObservableSampleTimed<T>

public class
ObservableSampleWithObservable<T>

public class
ObservableScalarXMap

Utility classes to work with scalar-sourced XMap operators (where X == { flat, concat, switch }).

public class
ObservableScan<T>

public class
ObservableScanSeed<T, R>

public class
ObservableSequenceEqual<T>

public class
ObservableSequenceEqualSingle<T>

public class
ObservableSerialized<T>

public class
ObservableSingleMaybe<T>

public class
ObservableSingleSingle<T>

public class
ObservableSkip<T>

public class
ObservableSkipLast<T>

public class
ObservableSkipLastTimed<T>

public class
ObservableSkipUntil<T, U>

public class
ObservableSkipWhile<T>

public class
ObservableSubscribeOn<T>

public class
ObservableSwitchIfEmpty<T>

public class
ObservableSwitchMap<T, R>

public class
ObservableTake<T>

public class
ObservableTakeLast<T>

public class
ObservableTakeLastOne<T>

public class
ObservableTakeLastTimed<T>

public class
ObservableTakeUntil<T, U>

public class
ObservableTakeUntilPredicate<T>

public class
ObservableTakeWhile<T>

public class
ObservableThrottleFirstTimed<T>

public class
ObservableThrottleLatest<
the upstream and downstream value type
T>

Emits the next or latest item when the given time elapses.

public class
ObservableTimeInterval<T>

public class
ObservableTimeout<T, U, V>

public class
ObservableTimeoutTimed<T>

public class
ObservableTimer

public class
ObservableToList<T, U extends Collection<? super T>>

public class
ObservableToListSingle<T, U extends Collection<? super T>>

public class
ObservableUnsubscribeOn<T>

public class
ObservableUsing<T, D>

public class
ObservableWindow<T>

public class
ObservableWindowBoundary<T, B>

public class
ObservableWindowBoundarySelector<T, B, V>

pack-priv class
ObservableWindowSubscribeIntercept<
the element type of the flow.
T>

Wrapper for a Subject that detects an incoming subscriber.

public class
ObservableWindowTimed<T>

public class
ObservableWithLatestFrom<T, U, R>

public class
ObservableWithLatestFromMany<
the main sequence's type
T,
the output type
R>

Combines a main sequence of values with the latest from multiple other sequences via a selector function.

public class
ObservableZip<T, R>

public class
ObservableZipIterable<T, U, V>

public class
ObserverResourceWrapper<T>