Package | Description |
---|---|
io.reactivex.internal.operators.flowable |
Modifier and Type | Class and Description |
---|---|
class |
FlowableAll<T> |
class |
FlowableAny<T> |
class |
FlowableBuffer<T,C extends Collection<? super T>> |
class |
FlowableBufferBoundary<T,U extends Collection<? super T>,Open,Close> |
class |
FlowableBufferBoundarySupplier<T,U extends Collection<? super T>,B> |
class |
FlowableBufferExactBoundary<T,U extends Collection<? super T>,B> |
class |
FlowableBufferTimed<T,U extends 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 |
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> |
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 |
FlowableLimit<T>
Limits both the total request amount and items received from the upstream.
|
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 |
FlowableOnErrorNext<T> |
class |
FlowableOnErrorReturn<T> |
class |
FlowablePublish<T>
A connectable observable which shares an underlying source and dispatches source values to subscribers in a backpressure-aware
manner.
|
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 |
FlowableReduceMaybe<T>
Reduce a Flowable into a single value exposed as Single or signal NoSuchElementException.
|
class |
FlowableRepeat<T> |
class |
FlowableRepeatUntil<T> |
class |
FlowableRepeatWhen<T> |
class |
FlowableReplay<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 Collection<? super T>> |
class |
FlowableUnsubscribeOn<T> |
class |
FlowableWindow<T> |
class |
FlowableWindowBoundary<T,B> |
class |
FlowableWindowBoundarySelector<T,B,V> |
class |
FlowableWindowBoundarySupplier<T,B> |
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> |
Copyright © 2018 JBoss by Red Hat. All rights reserved.