Class | Description |
---|---|
BlockingObservableIterable<T> | |
BlockingObservableLatest<T> |
Wait for and iterate over the latest values of the source observable.
|
BlockingObservableMostRecent<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.
|
BlockingObservableNext<T> |
Returns an Iterable that blocks until the Observable emits another item, then returns that item.
|
ObservableAll<T> | |
ObservableAllSingle<T> | |
ObservableAmb<T> | |
ObservableAny<T> | |
ObservableAnySingle<T> | |
ObservableAutoConnect<T> |
Wraps a ConnectableObservable and calls its connect() method once
the specified number of Observers have subscribed.
|
ObservableBlockingSubscribe |
Utility methods to consume an Observable in a blocking manner with callbacks or Observer.
|
ObservableBuffer<T,U extends Collection<? super T>> | |
ObservableBufferBoundary<T,U extends Collection<? super T>,Open,Close> | |
ObservableBufferBoundarySupplier<T,U extends Collection<? super T>,B> | |
ObservableBufferExactBoundary<T,U extends Collection<? super T>,B> | |
ObservableBufferTimed<T,U extends Collection<? super T>> | |
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.
|
ObservableCollect<T,U> | |
ObservableCollectSingle<T,U> | |
ObservableCombineLatest<T,R> | |
ObservableConcatMap<T,U> | |
ObservableConcatMapEager<T,R> | |
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.
|
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.
|
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.
|
ObservableCount<T> | |
ObservableCountSingle<T> | |
ObservableCreate<T> | |
ObservableDebounce<T,U> | |
ObservableDebounceTimed<T> | |
ObservableDefer<T> | |
ObservableDelay<T> | |
ObservableDelaySubscriptionOther<T,U> |
Delays the subscription to the main source until the other
observable fires an event or completes.
|
ObservableDematerialize<T,R> | |
ObservableDetach<T> |
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> | |
ObservableDistinctUntilChanged<T,K> | |
ObservableDoAfterNext<T> |
Calls a consumer after pushing the current item to the downstream.
|
ObservableDoFinally<T> |
Execute an action after an onError, onComplete or a dispose event.
|
ObservableDoOnEach<T> | |
ObservableDoOnLifecycle<T> | |
ObservableElementAt<T> | |
ObservableElementAtMaybe<T> | |
ObservableElementAtSingle<T> | |
ObservableEmpty | |
ObservableError<T> | |
ObservableFilter<T> | |
ObservableFlatMap<T,U> | |
ObservableFlatMapCompletable<T> |
Maps a sequence of values into CompletableSources and awaits their termination.
|
ObservableFlatMapCompletableCompletable<T> |
Maps a sequence of values into CompletableSources and awaits their termination.
|
ObservableFlatMapMaybe<T,R> |
Maps upstream values into MaybeSources and merges their signals into one sequence.
|
ObservableFlatMapSingle<T,R> |
Maps upstream values into SingleSources and merges their signals into one sequence.
|
ObservableFlattenIterable<T,R> |
Maps a sequence into an Iterable and emits its values.
|
ObservableFromArray<T> | |
ObservableFromCallable<T> |
Calls a Callable and emits its resulting single value or signals its exception.
|
ObservableFromFuture<T> | |
ObservableFromIterable<T> | |
ObservableFromPublisher<T> | |
ObservableFromUnsafeSource<T> | |
ObservableGenerate<T,S> | |
ObservableGroupBy<T,K,V> | |
ObservableGroupBy.GroupByObserver<T,K,V> | |
ObservableGroupJoin<TLeft,TRight,TLeftEnd,TRightEnd,R> | |
ObservableHide<T> |
Hides the identity of the wrapped ObservableSource and its Disposable.
|
ObservableIgnoreElements<T> | |
ObservableIgnoreElementsCompletable<T> | |
ObservableInternalHelper |
Helper utility class to support Observable with inner classes.
|
ObservableInterval | |
ObservableIntervalRange | |
ObservableJoin<TLeft,TRight,TLeftEnd,TRightEnd,R> | |
ObservableJust<T> |
Represents a constant scalar value.
|
ObservableLastMaybe<T> |
Consumes the source ObservableSource and emits its last item, the defaultItem
if empty or a NoSuchElementException if even the defaultItem is null.
|
ObservableLastSingle<T> |
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> | |
ObservableMapNotification<T,R> | |
ObservableMaterialize<T> | |
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.
|
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.
|
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.
|
ObservableNever | |
ObservableObserveOn<T> | |
ObservableOnErrorNext<T> | |
ObservableOnErrorReturn<T> | |
ObservablePublish<T> |
A connectable observable which shares an underlying source and dispatches source values to observers in a backpressure-aware
manner.
|
ObservablePublishSelector<T,R> |
Shares a source Observable for the duration of a selector function.
|
ObservableRange |
Emits a range of integer values from start to end.
|
ObservableRangeLong | |
ObservableReduceMaybe<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.
|
ObservableReduceSeedSingle<T,R> |
Reduce a sequence of values, starting from a seed value and by using
an accumulator function and return the last accumulated value.
|
ObservableReduceWithSingle<T,R> |
Reduce a sequence of values, starting from a generated seed value and by using
an accumulator function and return the last accumulated value.
|
ObservableRefCount<T> |
Returns an observable sequence that stays connected to the source as long as
there is at least one subscription to the observable sequence.
|
ObservableRepeat<T> | |
ObservableRepeatUntil<T> | |
ObservableRepeatWhen<T> |
Repeatedly subscribe to a source if a handler ObservableSource signals an item.
|
ObservableReplay<T> | |
ObservableRetryBiPredicate<T> | |
ObservableRetryPredicate<T> | |
ObservableRetryWhen<T> |
Repeatedly subscribe to a source if a handler ObservableSource signals an item.
|
ObservableSampleTimed<T> | |
ObservableSampleWithObservable<T> | |
ObservableScalarXMap |
Utility classes to work with scalar-sourced XMap operators (where X == { flat, concat, switch }).
|
ObservableScalarXMap.ScalarDisposable<T> |
Represents a Disposable that signals one onNext followed by an onComplete.
|
ObservableScan<T> | |
ObservableScanSeed<T,R> | |
ObservableSequenceEqual<T> | |
ObservableSequenceEqualSingle<T> | |
ObservableSerialized<T> | |
ObservableSingleMaybe<T> | |
ObservableSingleSingle<T> | |
ObservableSkip<T> | |
ObservableSkipLast<T> | |
ObservableSkipLastTimed<T> | |
ObservableSkipUntil<T,U> | |
ObservableSkipWhile<T> | |
ObservableSubscribeOn<T> | |
ObservableSwitchIfEmpty<T> | |
ObservableSwitchMap<T,R> | |
ObservableTake<T> | |
ObservableTakeLast<T> | |
ObservableTakeLastOne<T> | |
ObservableTakeLastTimed<T> | |
ObservableTakeUntil<T,U> | |
ObservableTakeUntilPredicate<T> | |
ObservableTakeWhile<T> | |
ObservableThrottleFirstTimed<T> | |
ObservableThrottleLatest<T> |
Emits the next or latest item when the given time elapses.
|
ObservableTimeInterval<T> | |
ObservableTimeout<T,U,V> | |
ObservableTimeoutTimed<T> | |
ObservableTimer | |
ObservableToList<T,U extends Collection<? super T>> | |
ObservableToListSingle<T,U extends Collection<? super T>> | |
ObservableUnsubscribeOn<T> | |
ObservableUsing<T,D> | |
ObservableWindow<T> | |
ObservableWindowBoundary<T,B> | |
ObservableWindowBoundarySelector<T,B,V> | |
ObservableWindowBoundarySupplier<T,B> | |
ObservableWindowTimed<T> | |
ObservableWithLatestFrom<T,U,R> | |
ObservableWithLatestFromMany<T,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> | |
ObserverResourceWrapper<T> |
Copyright © 2019. All rights reserved.