(package private) class |
AbstractObservableWithUpstream<T,U> |
Base class for operators with a source consumable.
|
class |
ObservableAll<T> |
|
class |
ObservableAny<T> |
|
class |
ObservableBuffer<T,U extends java.util.Collection<? super T>> |
|
class |
ObservableBufferBoundary<T,U extends java.util.Collection<? super T>,Open,Close> |
|
class |
ObservableBufferExactBoundary<T,U extends java.util.Collection<? super T>,B> |
|
class |
ObservableBufferTimed<T,U extends java.util.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 |
ObservableConcatMapScheduler<T,U> |
|
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 |
ObservableOnErrorComplete<T> |
Emits an onComplete if the source emits an onError and the predicate returns true for
that Throwable.
|
class |
ObservableOnErrorNext<T> |
|
class |
ObservableOnErrorReturn<T> |
|
class |
ObservablePublish<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.
|
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 java.util.Collection<? super T>> |
|
class |
ObservableUnsubscribeOn<T> |
|
class |
ObservableWindow<T> |
|
class |
ObservableWindowBoundary<T,B> |
|
class |
ObservableWindowBoundarySelector<T,B,V> |
|
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.
|