class |
FlowableAll<T> |
|
class |
FlowableAny<T> |
|
class |
FlowableBuffer<T,C extends java.util.Collection<? super T>> |
|
class |
FlowableBufferBoundary<T,U extends java.util.Collection<? super T>,Open,Close> |
|
class |
FlowableBufferExactBoundary<T,U extends java.util.Collection<? super T>,B> |
|
class |
FlowableBufferTimed<T,U extends java.util.Collection<? super T>> |
|
class |
FlowableCache<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 |
FlowableCollect<T,U> |
|
class |
FlowableConcatMap<T,R> |
|
class |
FlowableConcatMapEager<T,R> |
|
class |
FlowableConcatMapScheduler<T,R> |
|
class |
FlowableConcatWithCompletable<T> |
Subscribe to a main Flowable first, then when it completes normally, subscribe to a Completable
and terminate when it terminates.
|
class |
FlowableConcatWithMaybe<T> |
Subscribe to a main Flowable 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 |
FlowableConcatWithSingle<T> |
Subscribe to a main Flowable 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 |
FlowableCount<T> |
|
class |
FlowableDebounce<T,U> |
|
class |
FlowableDebounceTimed<T> |
|
class |
FlowableDelay<T> |
|
class |
FlowableDematerialize<T,R> |
|
class |
FlowableDetach<T> |
|
class |
FlowableDistinct<T,K> |
|
class |
FlowableDistinctUntilChanged<T,K> |
|
class |
FlowableDoAfterNext<T> |
Calls a consumer after pushing the current item to the downstream.
|
class |
FlowableDoFinally<T> |
Execute an action after an onError, onComplete or a cancel event.
|
class |
FlowableDoOnEach<T> |
|
class |
FlowableDoOnLifecycle<T> |
|
class |
FlowableElementAt<T> |
|
class |
FlowableFilter<T> |
|
class |
FlowableFlatMap<T,U> |
|
class |
FlowableFlatMapCompletable<T> |
Maps a sequence of values into CompletableSources and awaits their termination.
|
class |
FlowableFlatMapMaybe<T,R> |
Maps upstream values into MaybeSources and merges their signals into one sequence.
|
class |
FlowableFlatMapSingle<T,R> |
Maps upstream values into SingleSources and merges their signals into one sequence.
|
class |
FlowableFlattenIterable<T,R> |
|
class |
FlowableGroupBy<T,K,V> |
|
class |
FlowableGroupJoin<TLeft,TRight,TLeftEnd,TRightEnd,R> |
|
class |
FlowableHide<T> |
Hides the identity of the wrapped Flowable and its Subscription.
|
class |
FlowableIgnoreElements<T> |
|
class |
FlowableJoin<TLeft,TRight,TLeftEnd,TRightEnd,R> |
|
class |
FlowableLift<R,T> |
Allows lifting operators into a chain of Publishers.
|
class |
FlowableMap<T,U> |
|
class |
FlowableMapNotification<T,R> |
|
class |
FlowableMaterialize<T> |
|
class |
FlowableMergeWithCompletable<T> |
Merges a Flowable and a Completable by emitting the items of the Flowable and waiting until
both the Flowable and Completable complete normally.
|
class |
FlowableMergeWithMaybe<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 |
FlowableMergeWithSingle<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 |
FlowableObserveOn<T> |
|
class |
FlowableOnBackpressureBuffer<T> |
|
class |
FlowableOnBackpressureBufferStrategy<T> |
Handle backpressure with a bounded buffer and custom strategy.
|
class |
FlowableOnBackpressureDrop<T> |
|
class |
FlowableOnBackpressureError<T> |
|
class |
FlowableOnBackpressureLatest<T> |
|
class |
FlowableOnBackpressureReduce<T> |
|
class |
FlowableOnBackpressureReduceWith<T,R> |
|
class |
FlowableOnErrorComplete<T> |
Emits an onComplete if the source emits an onError and the predicate returns true for
that Throwable.
|
class |
FlowableOnErrorNext<T> |
|
class |
FlowableOnErrorReturn<T> |
|
class |
FlowablePublishMulticast<T,R> |
Multicasts a Flowable over a selector function.
|
class |
FlowableReduce<T> |
Reduces a sequence via a function into a single value or signals NoSuchElementException for
an empty source.
|
class |
FlowableRepeat<T> |
|
class |
FlowableRepeatUntil<T> |
|
class |
FlowableRepeatWhen<T> |
|
class |
FlowableRetryBiPredicate<T> |
|
class |
FlowableRetryPredicate<T> |
|
class |
FlowableRetryWhen<T> |
|
class |
FlowableSampleTimed<T> |
|
class |
FlowableScan<T> |
|
class |
FlowableScanSeed<T,R> |
|
class |
FlowableSerialized<T> |
|
class |
FlowableSingle<T> |
|
class |
FlowableSkip<T> |
|
class |
FlowableSkipLast<T> |
|
class |
FlowableSkipLastTimed<T> |
|
class |
FlowableSkipUntil<T,U> |
|
class |
FlowableSkipWhile<T> |
|
class |
FlowableSubscribeOn<T> |
Subscribes to the source Flowable on the specified Scheduler and makes
sure downstream requests are scheduled there as well.
|
class |
FlowableSwitchIfEmpty<T> |
|
class |
FlowableSwitchMap<T,R> |
|
class |
FlowableTake<T> |
|
class |
FlowableTakeLast<T> |
|
class |
FlowableTakeLastOne<T> |
|
class |
FlowableTakeLastTimed<T> |
|
class |
FlowableTakeUntil<T,U> |
|
class |
FlowableTakeUntilPredicate<T> |
|
class |
FlowableTakeWhile<T> |
|
class |
FlowableThrottleFirstTimed<T> |
|
class |
FlowableThrottleLatest<T> |
Emits the next or latest item when the given time elapses.
|
class |
FlowableTimeInterval<T> |
|
class |
FlowableTimeout<T,U,V> |
|
class |
FlowableTimeoutTimed<T> |
|
class |
FlowableToList<T,U extends java.util.Collection<? super T>> |
|
class |
FlowableUnsubscribeOn<T> |
|
class |
FlowableWindow<T> |
|
class |
FlowableWindowBoundary<T,B> |
|
class |
FlowableWindowBoundarySelector<T,B,V> |
|
class |
FlowableWindowTimed<T> |
|
class |
FlowableWithLatestFrom<T,U,R> |
|
class |
FlowableWithLatestFromMany<T,R> |
Combines a main sequence of values with the latest from multiple other sequences via
a selector function.
|
class |
FlowableZipIterable<T,U,V> |
|