Class | Description |
---|---|
BlockingFlowableIterable<T> | |
BlockingFlowableLatest<T> |
Wait for and iterate over the latest values of the source observable.
|
BlockingFlowableMostRecent<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.
|
BlockingFlowableNext<T> |
Returns an Iterable that blocks until the Observable emits another item, then returns that item.
|
FlowableAll<T> | |
FlowableAllSingle<T> | |
FlowableAmb<T> | |
FlowableAny<T> | |
FlowableAnySingle<T> | |
FlowableAutoConnect<T> |
Wraps a
ConnectableFlowable and calls its connect() method once
the specified number of Subscriber s have subscribed. |
FlowableBlockingSubscribe |
Utility methods to consume a Publisher in a blocking manner with callbacks or Subscriber.
|
FlowableBuffer<T,C extends Collection<? super T>> | |
FlowableBufferBoundary<T,U extends Collection<? super T>,Open,Close> | |
FlowableBufferBoundarySupplier<T,U extends Collection<? super T>,B> | |
FlowableBufferExactBoundary<T,U extends Collection<? super T>,B> | |
FlowableBufferTimed<T,U extends Collection<? super T>> | |
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.
|
FlowableCollect<T,U> | |
FlowableCollectSingle<T,U> | |
FlowableCombineLatest<T,R> |
Combines the latest values from multiple sources through a function.
|
FlowableConcatArray<T> | |
FlowableConcatMap<T,R> | |
FlowableConcatMapEager<T,R> | |
FlowableConcatMapEagerPublisher<T,R> |
ConcatMapEager which works with an arbitrary Publisher source.
|
FlowableConcatMapPublisher<T,R> | |
FlowableConcatWithCompletable<T> |
Subscribe to a main Flowable first, then when it completes normally, subscribe to a Completable
and terminate when it terminates.
|
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.
|
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.
|
FlowableCount<T> | |
FlowableCountSingle<T> | |
FlowableCreate<T> | |
FlowableDebounce<T,U> | |
FlowableDebounceTimed<T> | |
FlowableDefer<T> | |
FlowableDelay<T> | |
FlowableDelaySubscriptionOther<T,U> |
Delays the subscription to the main source until the other
observable fires an event or completes.
|
FlowableDematerialize<T,R> | |
FlowableDetach<T> | |
FlowableDistinct<T,K> | |
FlowableDistinctUntilChanged<T,K> | |
FlowableDoAfterNext<T> |
Calls a consumer after pushing the current item to the downstream.
|
FlowableDoFinally<T> |
Execute an action after an onError, onComplete or a cancel event.
|
FlowableDoOnEach<T> | |
FlowableDoOnLifecycle<T> | |
FlowableElementAt<T> | |
FlowableElementAtMaybe<T> | |
FlowableElementAtSingle<T> | |
FlowableEmpty |
A source Flowable that signals an onSubscribe() + onComplete() only.
|
FlowableError<T> | |
FlowableFilter<T> | |
FlowableFlatMap<T,U> | |
FlowableFlatMapCompletable<T> |
Maps a sequence of values into CompletableSources and awaits their termination.
|
FlowableFlatMapCompletableCompletable<T> |
Maps a sequence of values into CompletableSources and awaits their termination.
|
FlowableFlatMapMaybe<T,R> |
Maps upstream values into MaybeSources and merges their signals into one sequence.
|
FlowableFlatMapPublisher<T,U> | |
FlowableFlatMapSingle<T,R> |
Maps upstream values into SingleSources and merges their signals into one sequence.
|
FlowableFlattenIterable<T,R> | |
FlowableFromArray<T> | |
FlowableFromCallable<T> | |
FlowableFromFuture<T> | |
FlowableFromIterable<T> | |
FlowableFromObservable<T> | |
FlowableFromPublisher<T> | |
FlowableGenerate<T,S> | |
FlowableGroupBy<T,K,V> | |
FlowableGroupBy.GroupBySubscriber<T,K,V> | |
FlowableGroupJoin<TLeft,TRight,TLeftEnd,TRightEnd,R> | |
FlowableHide<T> |
Hides the identity of the wrapped Flowable and its Subscription.
|
FlowableIgnoreElements<T> | |
FlowableIgnoreElementsCompletable<T> | |
FlowableInternalHelper |
Helper utility class to support Flowable with inner classes.
|
FlowableInterval | |
FlowableIntervalRange | |
FlowableJoin<TLeft,TRight,TLeftEnd,TRightEnd,R> | |
FlowableJust<T> |
Represents a constant scalar value.
|
FlowableLastMaybe<T> |
Consumes the source Publisher and emits its last item or completes.
|
FlowableLastSingle<T> |
Consumes the source Publisher and emits its last item or the defaultItem
if empty.
|
FlowableLift<R,T> |
Allows lifting operators into a chain of Publishers.
|
FlowableLimit<T> |
Limits both the total request amount and items received from the upstream.
|
FlowableMap<T,U> | |
FlowableMapNotification<T,R> | |
FlowableMapPublisher<T,U> |
Map working with an arbitrary Publisher source.
|
FlowableMaterialize<T> | |
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.
|
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.
|
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.
|
FlowableNever | |
FlowableObserveOn<T> | |
FlowableOnBackpressureBuffer<T> | |
FlowableOnBackpressureBufferStrategy<T> |
Handle backpressure with a bounded buffer and custom strategy.
|
FlowableOnBackpressureDrop<T> | |
FlowableOnBackpressureError<T> | |
FlowableOnBackpressureLatest<T> | |
FlowableOnErrorNext<T> | |
FlowableOnErrorReturn<T> | |
FlowablePublish<T> |
A connectable observable which shares an underlying source and dispatches source values to subscribers in a backpressure-aware
manner.
|
FlowablePublishMulticast<T,R> |
Multicasts a Flowable over a selector function.
|
FlowableRange |
Emits a range of integer values.
|
FlowableRangeLong |
Emits a range of long values.
|
FlowableReduce<T> |
Reduces a sequence via a function into a single value or signals NoSuchElementException for
an empty source.
|
FlowableReduceMaybe<T> |
Reduce a Flowable into a single value exposed as Single or signal NoSuchElementException.
|
FlowableReduceSeedSingle<T,R> |
Reduce a sequence of values, starting from a seed value and by using
an accumulator function and return the last accumulated value.
|
FlowableReduceWithSingle<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.
|
FlowableRefCount<T> |
Returns an observable sequence that stays connected to the source as long as
there is at least one subscription to the observable sequence.
|
FlowableRepeat<T> | |
FlowableRepeatUntil<T> | |
FlowableRepeatWhen<T> | |
FlowableReplay<T> | |
FlowableRetryBiPredicate<T> | |
FlowableRetryPredicate<T> | |
FlowableRetryWhen<T> | |
FlowableSamplePublisher<T> | |
FlowableSampleTimed<T> | |
FlowableScalarXMap |
Utility classes to work with scalar-sourced XMap operators (where X == { flat, concat, switch }).
|
FlowableScan<T> | |
FlowableScanSeed<T,R> | |
FlowableSequenceEqual<T> | |
FlowableSequenceEqualSingle<T> | |
FlowableSerialized<T> | |
FlowableSingle<T> | |
FlowableSingleMaybe<T> | |
FlowableSingleSingle<T> | |
FlowableSkip<T> | |
FlowableSkipLast<T> | |
FlowableSkipLastTimed<T> | |
FlowableSkipUntil<T,U> | |
FlowableSkipWhile<T> | |
FlowableSubscribeOn<T> |
Subscribes to the source Flowable on the specified Scheduler and makes
sure downstream requests are scheduled there as well.
|
FlowableSwitchIfEmpty<T> | |
FlowableSwitchMap<T,R> | |
FlowableTake<T> | |
FlowableTakeLast<T> | |
FlowableTakeLastOne<T> | |
FlowableTakeLastTimed<T> | |
FlowableTakePublisher<T> |
Take with a generic Publisher source.
|
FlowableTakeUntil<T,U> | |
FlowableTakeUntilPredicate<T> | |
FlowableTakeWhile<T> | |
FlowableThrottleFirstTimed<T> | |
FlowableThrottleLatest<T> |
Emits the next or latest item when the given time elapses.
|
FlowableTimeInterval<T> | |
FlowableTimeout<T,U,V> | |
FlowableTimeoutTimed<T> | |
FlowableTimer | |
FlowableToList<T,U extends Collection<? super T>> | |
FlowableToListSingle<T,U extends Collection<? super T>> | |
FlowableUnsubscribeOn<T> | |
FlowableUsing<T,D> | |
FlowableWindow<T> | |
FlowableWindowBoundary<T,B> | |
FlowableWindowBoundarySelector<T,B,V> | |
FlowableWindowBoundarySupplier<T,B> | |
FlowableWindowTimed<T> | |
FlowableWithLatestFrom<T,U,R> | |
FlowableWithLatestFromMany<T,R> |
Combines a main sequence of values with the latest from multiple other sequences via
a selector function.
|
FlowableZip<T,R> | |
FlowableZipIterable<T,U,V> |
Enum | Description |
---|---|
FlowableInternalHelper.RequestMax |
Copyright © 2019. All rights reserved.