| CachedObservable<T> |
An observable which auto-connects to another observable, caches the elements
from that observable but allows terminating the connection and completing the cache.
|
| ObservableScalarSource<T> |
Represents a constant scalar value.
|
| OperatorAll<T> |
|
| OperatorAny<T> |
|
| OperatorBuffer<T,U extends java.util.Collection<? super T>> |
|
| OperatorBufferBoundary<T,U extends java.util.Collection<? super T>,Open,Close> |
|
| OperatorBufferBoundarySupplier<T,U extends java.util.Collection<? super T>,B> |
|
| OperatorBufferExactBoundary<T,U extends java.util.Collection<? super T>,B> |
|
| OperatorBufferTimed<T,U extends java.util.Collection<? super T>> |
|
| OperatorCollect<T,U> |
|
| OperatorConcatMap<T,U> |
|
| OperatorDebounce<T,U> |
|
| OperatorDebounceTimed<T> |
|
| OperatorDelay<T> |
|
| OperatorDistinct<T,K> |
|
| OperatorDoOnEach<T> |
|
| OperatorElementAt<T> |
|
| OperatorFilter<T> |
|
| OperatorFlatMap<T,U> |
|
| OperatorGroupBy<T,K,V> |
|
| OperatorGroupBy.GroupBySubscriber<T,K,V> |
|
| OperatorMap<T,U> |
|
| OperatorMapNotification<T,R> |
|
| OperatorObserveOn<T> |
|
| OperatorOnBackpressureBuffer<T> |
|
| OperatorOnBackpressureDrop<T> |
|
| OperatorOnErrorNext<T> |
|
| OperatorOnErrorReturn<T> |
|
| OperatorPublish<T> |
A connectable observable which shares an underlying source and dispatches source values to subscribers in a backpressure-aware
manner.
|
| OperatorReplay<T> |
|
| OperatorSamplePublisher<T> |
|
| OperatorSampleTimed<T> |
|
| OperatorScan<T> |
|
| OperatorScanSeed<T,R> |
|
| OperatorSingle<T> |
|
| OperatorSkip<T> |
|
| OperatorSkipLast<T> |
|
| OperatorSkipLastTimed<T> |
|
| OperatorSkipUntil<T,U> |
|
| OperatorSkipWhile<T> |
|
| OperatorSwitchIfEmpty<T> |
|
| OperatorSwitchMap<T,R> |
|
| OperatorTake<T> |
|
| OperatorTakeLast<T> |
|
| OperatorTakeLastTimed<T> |
|
| OperatorTakeUntil<T,U> |
|
| OperatorTakeUntilPredicate<T> |
|
| OperatorTakeWhile<T> |
|
| OperatorThrottleFirstTimed<T> |
|
| OperatorTimeInterval<T> |
|
| OperatorTimeout<T,U,V> |
|
| OperatorTimeoutTimed<T> |
|
| OperatorToList<T,U extends java.util.Collection<? super T>> |
|
| OperatorUnsubscribeOn<T> |
|
| OperatorWindow<T> |
|
| OperatorWindowBoundary<T,B> |
|
| OperatorWindowBoundarySelector<T,B,V> |
|
| OperatorWindowBoundarySupplier<T,B> |
|
| OperatorWindowTimed<T> |
|
| OperatorWithLatestFrom<T,U,R> |
|
| PublisherAmb<T> |
|
| PublisherArraySource<T> |
|
| PublisherAutoConnect<T> |
Wraps a ConnectableObservable and calls its connect() method once
the specified number of Subscribers have subscribed.
|
| PublisherCombineLatest<T,R> |
|
| PublisherDefer<T> |
|
| PublisherDelaySubscriptionOther<T,U> |
Delays the subscription to the main source until the other
observable fires an event or completes.
|
| PublisherErrorSource<T> |
|
| PublisherFutureSource<T> |
|
| PublisherGenerate<T,S> |
|
| PublisherIntervalOnceSource |
|
| PublisherIntervalRangeSource |
|
| PublisherIntervalSource |
|
| PublisherIterableSource<T> |
|
| PublisherLift<R,T> |
Allows lifting operators into a chain of Publishers.
|
| PublisherRangeSource |
|
| PublisherRedo<T> |
|
| PublisherRefCount<T> |
Returns an observable sequence that stays connected to the source as long as
there is at least one subscription to the observable sequence.
|
| PublisherRepeat<T> |
|
| PublisherRepeatUntil<T> |
|
| PublisherRetryBiPredicate<T> |
|
| PublisherRetryPredicate<T> |
|
| PublisherScalarAsyncSource<T> |
|
| PublisherSequenceEqual<T> |
|
| PublisherSubscribeOn<T> |
|
| PublisherUsing<T,D> |
|
| PublisherZip<T,R> |
|
| PublisherZipIterable<T,U,V> |
|
| SubscriberResourceWrapper<T,R> |
|