Package | Description |
---|---|
io.reactivex.internal.operators.observable |
Modifier and Type | Class and Description |
---|---|
class |
ObservableAll<T> |
class |
ObservableAny<T> |
class |
ObservableBuffer<T,U extends Collection<? super T>> |
class |
ObservableBufferBoundary<T,U extends Collection<? super T>,Open,Close> |
class |
ObservableBufferBoundarySupplier<T,U extends Collection<? super T>,B> |
class |
ObservableBufferExactBoundary<T,U extends Collection<? super T>,B> |
class |
ObservableBufferTimed<T,U extends Collection<? super T>> |
class |
ObservableCache<T>
An observable which auto-connects to another observable, caches the elements
from that observable but allows terminating the connection and completing the cache.
|
class |
ObservableCollect<T,U> |
class |
ObservableConcatMap<T,U> |
class |
ObservableConcatMapEager<T,R> |
class |
ObservableConcatWithCompletable<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.
|
class |
ObservableConcatWithMaybe<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.
|
class |
ObservableConcatWithSingle<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.
|
class |
ObservableCount<T> |
class |
ObservableDebounce<T,U> |
class |
ObservableDebounceTimed<T> |
class |
ObservableDelay<T> |
class |
ObservableDematerialize<T,R> |
class |
ObservableDetach<T>
Breaks the links between the upstream and the downstream (the Disposable and
the Observer references) when the sequence terminates or gets disposed.
|
class |
ObservableDistinct<T,K> |
class |
ObservableDistinctUntilChanged<T,K> |
class |
ObservableDoAfterNext<T>
Calls a consumer after pushing the current item to the downstream.
|
class |
ObservableDoFinally<T>
Execute an action after an onError, onComplete or a dispose event.
|
class |
ObservableDoOnEach<T> |
class |
ObservableDoOnLifecycle<T> |
class |
ObservableElementAt<T> |
class |
ObservableFilter<T> |
class |
ObservableFlatMap<T,U> |
class |
ObservableFlatMapCompletable<T>
Maps a sequence of values into CompletableSources and awaits their termination.
|
class |
ObservableFlatMapMaybe<T,R>
Maps upstream values into MaybeSources and merges their signals into one sequence.
|
class |
ObservableFlatMapSingle<T,R>
Maps upstream values into SingleSources and merges their signals into one sequence.
|
class |
ObservableFlattenIterable<T,R>
Maps a sequence into an Iterable and emits its values.
|
class |
ObservableGroupBy<T,K,V> |
class |
ObservableGroupJoin<TLeft,TRight,TLeftEnd,TRightEnd,R> |
class |
ObservableHide<T>
Hides the identity of the wrapped ObservableSource and its Disposable.
|
class |
ObservableIgnoreElements<T> |
class |
ObservableJoin<TLeft,TRight,TLeftEnd,TRightEnd,R> |
class |
ObservableLift<R,T>
Allows lifting operators into a chain of Observables.
|
class |
ObservableMap<T,U> |
class |
ObservableMapNotification<T,R> |
class |
ObservableMaterialize<T> |
class |
ObservableMergeWithCompletable<T>
Merges an Observable and a Completable by emitting the items of the Observable and waiting until
both the Observable and Completable complete normally.
|
class |
ObservableMergeWithMaybe<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.
|
class |
ObservableMergeWithSingle<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.
|
class |
ObservableObserveOn<T> |
class |
ObservableOnErrorNext<T> |
class |
ObservableOnErrorReturn<T> |
class |
ObservablePublish<T>
A connectable observable which shares an underlying source and dispatches source values to observers in a backpressure-aware
manner.
|
class |
ObservablePublishSelector<T,R>
Shares a source Observable for the duration of a selector function.
|
class |
ObservableRepeat<T> |
class |
ObservableRepeatUntil<T> |
class |
ObservableRepeatWhen<T>
Repeatedly subscribe to a source if a handler ObservableSource signals an item.
|
class |
ObservableReplay<T> |
class |
ObservableRetryBiPredicate<T> |
class |
ObservableRetryPredicate<T> |
class |
ObservableRetryWhen<T>
Repeatedly subscribe to a source if a handler ObservableSource signals an item.
|
class |
ObservableSampleTimed<T> |
class |
ObservableSampleWithObservable<T> |
class |
ObservableScan<T> |
class |
ObservableScanSeed<T,R> |
class |
ObservableSerialized<T> |
class |
ObservableSkip<T> |
class |
ObservableSkipLast<T> |
class |
ObservableSkipLastTimed<T> |
class |
ObservableSkipUntil<T,U> |
class |
ObservableSkipWhile<T> |
class |
ObservableSubscribeOn<T> |
class |
ObservableSwitchIfEmpty<T> |
class |
ObservableSwitchMap<T,R> |
class |
ObservableTake<T> |
class |
ObservableTakeLast<T> |
class |
ObservableTakeLastOne<T> |
class |
ObservableTakeLastTimed<T> |
class |
ObservableTakeUntil<T,U> |
class |
ObservableTakeUntilPredicate<T> |
class |
ObservableTakeWhile<T> |
class |
ObservableThrottleFirstTimed<T> |
class |
ObservableThrottleLatest<T>
Emits the next or latest item when the given time elapses.
|
class |
ObservableTimeInterval<T> |
class |
ObservableTimeout<T,U,V> |
class |
ObservableTimeoutTimed<T> |
class |
ObservableToList<T,U extends Collection<? super T>> |
class |
ObservableUnsubscribeOn<T> |
class |
ObservableWindow<T> |
class |
ObservableWindowBoundary<T,B> |
class |
ObservableWindowBoundarySelector<T,B,V> |
class |
ObservableWindowBoundarySupplier<T,B> |
class |
ObservableWindowTimed<T> |
class |
ObservableWithLatestFrom<T,U,R> |
class |
ObservableWithLatestFromMany<T,R>
Combines a main sequence of values with the latest from multiple other sequences via
a selector function.
|
Copyright © 2019. All rights reserved.