Uses of Interface
io.reactivex.rxjava3.functions.Function
Packages that use Function
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Contains the base type
ParallelFlowable
,
a sub-DSL for working with Flowable
sequences in parallel.Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.-
Uses of Function in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type FunctionModifier and TypeMethodDescriptionFlowable.buffer
(@NonNull org.reactivestreams.Publisher<? extends @NonNull TOpening> openingIndicator, @NonNull Function<? super @NonNull TOpening, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull TClosing>> closingIndicator) Returns aFlowable
that emits buffers of items it collects from the currentFlowable
.final <@NonNull TOpening,
@NonNull TClosing, @NonNull U extends Collection<? super @NonNull T>>
@NonNull Flowable<U> Flowable.buffer
(@NonNull org.reactivestreams.Publisher<? extends @NonNull TOpening> openingIndicator, @NonNull Function<? super @NonNull TOpening, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull TClosing>> closingIndicator, @NonNull Supplier<@NonNull U> bufferSupplier) Returns aFlowable
that emits buffers of items it collects from the currentFlowable
.Observable.buffer
(@NonNull ObservableSource<? extends @NonNull TOpening> openingIndicator, @NonNull Function<? super @NonNull TOpening, ? extends ObservableSource<? extends @NonNull TClosing>> closingIndicator) Returns anObservable
that emits buffers of items it collects from the currentObservable
.final <@NonNull TOpening,
@NonNull TClosing, @NonNull U extends Collection<? super @NonNull T>>
@NonNull Observable<U> Observable.buffer
(@NonNull ObservableSource<? extends @NonNull TOpening> openingIndicator, @NonNull Function<? super @NonNull TOpening, ? extends ObservableSource<? extends @NonNull TClosing>> closingIndicator, @NonNull Supplier<@NonNull U> bufferSupplier) Returns anObservable
that emits buffers of items it collects from the currentObservable
.Flowable.combineLatest
(@NonNull Iterable<@NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines a collection of sourcePublisher
s by emitting an item that aggregates the latest values of each of the sourcePublisher
s each time an item is received from any of the sourcePublisher
s, where this aggregation is defined by a specified function.Flowable.combineLatest
(@NonNull Iterable<@NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines a collection of sourcePublisher
s by emitting an item that aggregates the latest values of each of the sourcePublisher
s each time an item is received from any of the sourcePublisher
s, where this aggregation is defined by a specified function.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatest
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines a collection of sourceObservableSource
s by emitting an item that aggregates the latest values of each of the returnedObservableSource
s each time an item is received from any of the returnedObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatest
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines anIterable
of sourceObservableSource
s by emitting an item that aggregates the latest values of each of the returnedObservableSource
s each time an item is received from any of the returnedObservableSource
s, where this aggregation is defined by a specified function.Flowable.combineLatestArray
(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines a collection of sourcePublisher
s by emitting an item that aggregates the latest values of each of the sourcePublisher
s each time an item is received from any of the sourcePublisher
s, where this aggregation is defined by a specified function.Flowable.combineLatestArray
(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines a collection of sourcePublisher
s by emitting an item that aggregates the latest values of each of the sourcePublisher
s each time an item is received from any of the sourcePublisher
s, where this aggregation is defined by a specified function.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestArray
(@NonNull ObservableSource<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines an array of sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of the returnedObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestArray
(@NonNull ObservableSource<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines an array of sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function.Flowable.combineLatestArrayDelayError
(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines a collection of sourcePublisher
s by emitting an item that aggregates the latest values of each of the sourcePublisher
s each time an item is received from any of the sourcePublisher
s, where this aggregation is defined by a specified function.Flowable.combineLatestArrayDelayError
(@NonNull org.reactivestreams.Publisher<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines a collection of sourcePublisher
s by emitting an item that aggregates the latest values of each of the sourcePublisher
s each time an item is received from any of the sourcePublisher
s, where this aggregation is defined by a specified function and delays any error from the sources until all sourcePublisher
s terminate.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestArrayDelayError
(@NonNull ObservableSource<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines an array ofObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestArrayDelayError
(@NonNull ObservableSource<? extends @NonNull T>[] sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines an array ofObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function and delays any error from the sources until all sourceObservableSource
s terminate.Flowable.combineLatestDelayError
(@NonNull Iterable<@NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines a collection of sourcePublisher
s by emitting an item that aggregates the latest values of each of the sourcePublisher
s each time an item is received from any of the sourcePublisher
s, where this aggregation is defined by a specified function and delays any error from the sources until all sourcePublisher
s terminate.Flowable.combineLatestDelayError
(@NonNull Iterable<@NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines a collection of sourcePublisher
s by emitting an item that aggregates the latest values of each of the sourcePublisher
s each time an item is received from any of the sourcePublisher
s, where this aggregation is defined by a specified function and delays any error from the sources until all sourcePublisher
s terminate.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestDelayError
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner) Combines anIterable
ofObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function and delays any error from the sources until all sourceObservableSource
s terminate.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.combineLatestDelayError
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> combiner, int bufferSize) Combines anIterable
ofObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from any of theObservableSource
s, where this aggregation is defined by a specified function and delays any error from the sources until all sourceObservableSource
s terminate.Flowable.concatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Returns a newFlowable
that emits items resulting from applying a function that you supply to each item emitted by the currentFlowable
, where that function returns aPublisher
, and then emitting the items that result from concatenating those returnedPublisher
s.Flowable.concatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int prefetch) Returns a newFlowable
that emits items resulting from applying a function that you supply to each item emitted by the currentFlowable
, where that function returns aPublisher
, and then emitting the items that result from concatenating those returnedPublisher
s.Flowable.concatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int prefetch, @NonNull Scheduler scheduler) Returns a newFlowable
that emits items resulting from applying a function (on a designated scheduler) that you supply to each item emitted by the currentFlowable
, where that function returns aPublisher
, and then emitting the items that result from concatenating those returnedPublisher
s.Maybe.concatMap
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Returns aMaybe
that is based on applying a specified function to the item emitted by the currentMaybe
, where that function returns aMaybeSource
.final <@NonNull R>
@NonNull Observable<R> Observable.concatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Returns a newObservable
that emits items resulting from applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then emitting the items that result from concatenating those returnedObservableSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.concatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int bufferSize) Returns a newObservable
that emits items resulting from applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then emitting the items that result from concatenating those returnedObservableSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.concatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int bufferSize, @NonNull Scheduler scheduler) Returns a newObservable
that emits items resulting from applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then emitting the items that result from concatenating those returnedObservableSource
s.Single.concatMap
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Returns aSingle
that is based on applying a specified function to the item emitted by the currentSingle
, where that function returns aSingleSource
.final @NonNull Completable
Flowable.concatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Maps the upstream items intoCompletableSource
s and subscribes to them one after the other completes.final @NonNull Completable
Flowable.concatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, int prefetch) Maps the upstream items intoCompletableSource
s and subscribes to them one after the other completes.final @NonNull Completable
Maybe.concatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Returns aCompletable
that completes based on applying a specified function to the item emitted by the currentMaybe
, where that function returns aCompletable
.final @NonNull Completable
Observable.concatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Maps each element of the currentObservable
intoCompletableSource
s, subscribes to them one at a time in order and waits until the upstream and allCompletableSource
s complete.final @NonNull Completable
Observable.concatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, int capacityHint) Maps each element of the currentObservable
intoCompletableSource
s, subscribes to them one at a time in order and waits until the upstream and allCompletableSource
s complete.final @NonNull Completable
Single.concatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Returns aCompletable
that completes based on applying a specified function to the item emitted by the currentSingle
, where that function returns aCompletableSource
.final @NonNull Completable
Flowable.concatMapCompletableDelayError
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Maps the upstream items intoCompletableSource
s and subscribes to them one after the other terminates, delaying all errors till both thisFlowable
and all innerCompletableSource
s terminate.final @NonNull Completable
Flowable.concatMapCompletableDelayError
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean tillTheEnd) Maps the upstream items intoCompletableSource
s and subscribes to them one after the other terminates, optionally delaying all errors till both thisFlowable
and all innerCompletableSource
s terminate.final @NonNull Completable
Flowable.concatMapCompletableDelayError
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean tillTheEnd, int prefetch) Maps the upstream items intoCompletableSource
s and subscribes to them one after the other terminates, optionally delaying all errors till both thisFlowable
and all innerCompletableSource
s terminate.final @NonNull Completable
Observable.concatMapCompletableDelayError
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Maps the upstream items intoCompletableSource
s and subscribes to them one after the other terminates, delaying all errors till both the currentObservable
and all innerCompletableSource
s terminate.final @NonNull Completable
Observable.concatMapCompletableDelayError
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean tillTheEnd) Maps the upstream items intoCompletableSource
s and subscribes to them one after the other terminates, optionally delaying all errors till both the currentObservable
and all innerCompletableSource
s terminate.final @NonNull Completable
Observable.concatMapCompletableDelayError
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean tillTheEnd, int bufferSize) Maps the upstream items intoCompletableSource
s and subscribes to them one after the other terminates, optionally delaying all errors till both the currentObservable
and all innerCompletableSource
s terminate.Flowable.concatMapDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Maps each of the items into aPublisher
, subscribes to them one after the other, one at a time and emits their values in order while delaying any error from either this or any of the innerPublisher
s till all of them terminate.Flowable.concatMapDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean tillTheEnd, int prefetch) Maps each of the items into aPublisher
, subscribes to them one after the other, one at a time and emits their values in order while delaying any error from either this or any of the innerPublisher
s till all of them terminate.Flowable.concatMapDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean tillTheEnd, int prefetch, @NonNull Scheduler scheduler) Maps each of the upstream items into aPublisher
, subscribes to them one after the other, one at a time and emits their values in order while executing the mapper function on the designated scheduler, delaying any error from either this or any of the innerPublisher
s till all of them terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Maps each of the items into anObservableSource
, subscribes to them one after the other, one at a time and emits their values in order while delaying any error from either this or any of the innerObservableSource
s till all of them terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int bufferSize) Maps each of the items into anObservableSource
, subscribes to them one after the other, one at a time and emits their values in order while delaying any error from either this or any of the innerObservableSource
s till all of them terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int bufferSize, @NonNull Scheduler scheduler) Maps each of the items into anObservableSource
, subscribes to them one after the other, one at a time and emits their values in order while delaying any error from either this or any of the innerObservableSource
s till all of them terminate.Flowable.concatMapEager
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Maps a sequence of values intoPublisher
s and concatenates thesePublisher
s eagerly into a singlePublisher
.Flowable.concatMapEager
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int maxConcurrency, int prefetch) Maps a sequence of values intoPublisher
s and concatenates thesePublisher
s eagerly into a singlePublisher
.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapEager
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Maps a sequence of values intoObservableSource
s and concatenates theseObservableSource
s eagerly into a singleObservable
sequence.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapEager
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int maxConcurrency, int bufferSize) Maps a sequence of values intoObservableSource
s and concatenates theseObservableSource
s eagerly into a singleObservable
sequence.Flowable.concatMapEagerDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean tillTheEnd) Maps a sequence of values intoPublisher
s and concatenates thesePublisher
s eagerly into a singlePublisher
.Flowable.concatMapEagerDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean tillTheEnd, int maxConcurrency, int prefetch) Maps a sequence of values intoPublisher
s and concatenates thesePublisher
s eagerly into a singleFlowable
sequence.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapEagerDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean tillTheEnd) Maps a sequence of values intoObservableSource
s and concatenates theseObservableSource
s eagerly into a singleObservable
sequence.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapEagerDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int maxConcurrency, int bufferSize) Maps a sequence of values intoObservableSource
s and concatenates theseObservableSource
s eagerly into a singleObservable
sequence.Flowable.concatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) Returns aFlowable
that concatenate each item emitted by the currentFlowable
with the values in anIterable
corresponding to that item that is generated by a selector.Flowable.concatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper, int prefetch) Returns aFlowable
that concatenate each item emitted by the currentFlowable
with the values in anIterable
corresponding to that item that is generated by a selector.final <@NonNull U>
@NonNull Observable<U> Observable.concatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) Returns anObservable
that concatenate each item emitted by the currentObservable
with the values in anIterable
corresponding to that item that is generated by a selector.Flowable.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other succeeds or completes, emits their success value if available or terminates immediately if either thisFlowable
or the current innerMaybeSource
fail.Flowable.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, int prefetch) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other succeeds or completes, emits their success value if available or terminates immediately if either thisFlowable
or the current innerMaybeSource
fail.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other succeeds or completes, emits their success value if available or terminates immediately if either the currentObservable
or the current innerMaybeSource
fail.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, int bufferSize) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other succeeds or completes, emits their success value if available or terminates immediately if either the currentObservable
or the current innerMaybeSource
fail.Single.concatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Returns aMaybe
that is based on applying a specified function to the item emitted by the currentSingle
, where that function returns aMaybeSource
.Flowable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and delaying all errors till both thisFlowable
and all innerMaybeSource
s terminate.Flowable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean tillTheEnd) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and optionally delaying all errors till both thisFlowable
and all innerMaybeSource
s terminate.Flowable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int prefetch) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and optionally delaying all errors till both thisFlowable
and all innerMaybeSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and delaying all errors till both the currentObservable
and all innerMaybeSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean tillTheEnd) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and optionally delaying all errors till both the currentObservable
and all innerMaybeSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int bufferSize) Maps the upstream items intoMaybeSource
s and subscribes to them one after the other terminates, emits their success value if available and optionally delaying all errors till both the currentObservable
and all innerMaybeSource
s terminate.Flowable.concatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds, emits their success values or terminates immediately if either thisFlowable
or the current innerSingleSource
fail.Flowable.concatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, int prefetch) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds, emits their success values or terminates immediately if either thisFlowable
or the current innerSingleSource
fail.Maybe.concatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Returns aMaybe
based on applying a specified function to the item emitted by the currentMaybe
, where that function returns aSingle
.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds, emits their success values or terminates immediately if either the currentObservable
or the current innerSingleSource
fail.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, int bufferSize) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds, emits their success values or terminates immediately if either the currentObservable
or the current innerSingleSource
fail.Flowable.concatMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds or fails, emits their success values and delays all errors till both thisFlowable
and all innerSingleSource
s terminate.Flowable.concatMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, boolean tillTheEnd) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds or fails, emits their success values and optionally delays all errors till both thisFlowable
and all innerSingleSource
s terminate.Flowable.concatMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int prefetch) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds or fails, emits their success values and optionally delays errors till both thisFlowable
and all innerSingleSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds or fails, emits their success values and delays all errors till both the currentObservable
and all innerSingleSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, boolean tillTheEnd) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds or fails, emits their success values and optionally delays all errors till both the currentObservable
and all innerSingleSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, boolean tillTheEnd, int bufferSize) Maps the upstream items intoSingleSource
s and subscribes to them one after the other succeeds or fails, emits their success values and optionally delays errors till both the currentObservable
and all innerSingleSource
s terminate.Flowable.concatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps each upstream item into aStream
and emits theStream
's items to the downstream in a sequential fashion.Flowable.concatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper, int prefetch) Maps each upstream item into aStream
and emits theStream
's items to the downstream in a sequential fashion.final <@NonNull R>
@NonNull Observable<R> Observable.concatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps each upstream item into aStream
and emits theStream
's items to the downstream in a sequential fashion.Flowable.debounce
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<@NonNull U>> debounceIndicator) Returns aFlowable
that mirrors the currentFlowable
, except that it drops items emitted by the currentFlowable
that are followed by another item within a computed debounce duration.final <@NonNull U>
@NonNull Observable<T> Observable.debounce
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull U>> debounceIndicator) Returns anObservable
that mirrors the currentObservable
, except that it drops items emitted by the currentObservable
that are followed by another item within a computed debounce duration denoted by an item emission or completion from a generated innerObservableSource
for that original item.Flowable.delay
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<@NonNull U>> itemDelayIndicator) Returns aFlowable
that delays the emissions of the currentFlowable
via anotherPublisher
on a per-item basis.Flowable.delay
(@NonNull org.reactivestreams.Publisher<@NonNull U> subscriptionIndicator, @NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<@NonNull V>> itemDelayIndicator) Returns aFlowable
that delays the subscription to and emissions from the currentFlowable
via anotherPublisher
on a per-item basis.final <@NonNull U,
@NonNull V>
@NonNull Observable<T> Observable.delay
(@NonNull ObservableSource<@NonNull U> subscriptionIndicator, @NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull V>> itemDelayIndicator) Returns anObservable
that delays the subscription to and emissions from the currentObservable
viaObservableSource
s for the subscription itself and on a per-item basis.final <@NonNull U>
@NonNull Observable<T> Observable.delay
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull U>> itemDelayIndicator) Returns anObservable
that delays the emissions of the currentObservable
via a per-item derivedObservableSource
's item emission or termination, on a per source item basis.Flowable.dematerialize
(@NonNull Function<@NonNull ? super @NonNull T, @NonNull Notification<@NonNull R>> selector) Returns aFlowable
that reverses the effect ofmaterialize
by transforming theNotification
objects extracted from the source items via a selector function into their respectiveSubscriber
signal types.Maybe.dematerialize
(@NonNull Function<? super @NonNull T, @NonNull Notification<@NonNull R>> selector) Maps theNotification
success value of the currentMaybe
back into normalonSuccess
,onError
oronComplete
signals.final <@NonNull R>
@NonNull Observable<R> Observable.dematerialize
(@NonNull Function<? super @NonNull T, Notification<@NonNull R>> selector) Returns anObservable
that reverses the effect ofmaterialize
by transforming theNotification
objects extracted from the source items via a selector function into their respectiveObserver
signal types.Single.dematerialize
(@NonNull Function<? super @NonNull T, @NonNull Notification<@NonNull R>> selector) Maps theNotification
success value of the currentSingle
back into normalonSuccess
,onError
oronComplete
signals as aMaybe
source.Returns aFlowable
that emits all items emitted by the currentFlowable
that are distinct according to a key selector function and based onObject.equals(Object)
comparison of the objects returned by the key selector function.Flowable.distinct
(@NonNull Function<? super @NonNull T, @NonNull K> keySelector, @NonNull Supplier<? extends Collection<? super @NonNull K>> collectionSupplier) Returns aFlowable
that emits all items emitted by the currentFlowable
that are distinct according to a key selector function and based onObject.equals(Object)
comparison of the objects returned by the key selector function.final <@NonNull K>
@NonNull Observable<T> Returns anObservable
that emits all items emitted by the currentObservable
that are distinct according to a key selector function and based onObject.equals(Object)
comparison of the objects returned by the key selector function.final <@NonNull K>
@NonNull Observable<T> Observable.distinct
(@NonNull Function<? super @NonNull T, @NonNull K> keySelector, @NonNull Supplier<? extends Collection<? super @NonNull K>> collectionSupplier) Returns anObservable
that emits all items emitted by the currentObservable
that are distinct according to a key selector function and based onObject.equals(Object)
comparison of the objects returned by the key selector function.Returns aFlowable
that emits all items emitted by the currentFlowable
that are distinct from their immediate predecessors, according to a key selector function and based onObject.equals(Object)
comparison of those objects returned by the key selector function.final <@NonNull K>
@NonNull Observable<T> Returns anObservable
that emits all items emitted by the currentObservable
that are distinct from their immediate predecessors, according to a key selector function and based onObject.equals(Object)
comparison of those objects returned by the key selector function.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Returns aFlowable
that emits items based on applying a function that you supply to each item emitted by the currentFlowable
, where that function returns aPublisher
, and then merging those resultingPublisher
s and emitting the results of this merger.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayErrors) Returns aFlowable
that emits items based on applying a function that you supply to each item emitted by the currentFlowable
, where that function returns aPublisher
, and then merging those resultingPublisher
s and emitting the results of this merger.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayErrors, int maxConcurrency) Returns aFlowable
that emits items based on applying a function that you supply to each item emitted by the currentFlowable
, where that function returns aPublisher
, and then merging those resultingPublisher
s and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to thesePublisher
s.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize) Returns aFlowable
that emits items based on applying a function that you supply to each item emitted by the currentFlowable
, where that function returns aPublisher
, and then merging those resultingPublisher
s and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to thesePublisher
s.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int maxConcurrency) Returns aFlowable
that emits items based on applying a function that you supply to each item emitted by the currentFlowable
, where that function returns aPublisher
, and then merging those resultingPublisher
s and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to thesePublisher
s.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> onNextMapper, @NonNull Function<? super Throwable, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends org.reactivestreams.Publisher<? extends @NonNull R>> onCompleteSupplier) Returns aFlowable
that applies a function to each item emitted or notification raised by the currentFlowable
and then flattens thePublisher
s returned from these functions and emits the resulting items.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> onNextMapper, @NonNull Function<Throwable, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends org.reactivestreams.Publisher<? extends @NonNull R>> onCompleteSupplier, int maxConcurrency) Returns aFlowable
that applies a function to each item emitted or notification raised by the currentFlowable
and then flattens thePublisher
s returned from these functions and emits the resulting items, while limiting the maximum number of concurrent subscriptions to thesePublisher
s.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner) Returns aFlowable
that emits the results of a specified function to the pair of values emitted by the currentFlowable
and a specified collectionPublisher
.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, boolean delayErrors) Returns aFlowable
that emits the results of a specified function to the pair of values emitted by the currentFlowable
and a specified innerPublisher
.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, boolean delayErrors, int maxConcurrency) Returns aFlowable
that emits the results of a specified function to the pair of values emitted by the currentFlowable
and a specified collectionPublisher
, while limiting the maximum number of concurrent subscriptions to thesePublisher
s.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, boolean delayErrors, int maxConcurrency, int bufferSize) Returns aFlowable
that emits the results of a specified function to the pair of values emitted by the currentFlowable
and a specified collectionPublisher
, while limiting the maximum number of concurrent subscriptions to thesePublisher
s.Flowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, int maxConcurrency) Returns aFlowable
that emits the results of a specified function to the pair of values emitted by the currentFlowable
and a specified collectionPublisher
, while limiting the maximum number of concurrent subscriptions to thesePublisher
s.Maybe.flatMap
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Returns aMaybe
that is based on applying a specified function to the item emitted by the currentMaybe
, where that function returns aMaybeSource
.Maybe.flatMap
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> onSuccessMapper, @NonNull Function<? super Throwable, ? extends MaybeSource<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends MaybeSource<? extends @NonNull R>> onCompleteSupplier) Maps theonSuccess
,onError
oronComplete
signals of the currentMaybe
into aMaybeSource
and emits thatMaybeSource
's signals.Maybe.flatMap
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner) Returns aMaybe
that emits the results of a specified function to the pair of values emitted by the currentMaybe
and a specified mappedMaybeSource
.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Returns anObservable
that emits items based on applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then merging those returnedObservableSource
s and emitting the results of this merger.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean delayErrors) Returns anObservable
that emits items based on applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then merging those returnedObservableSource
s and emitting the results of this merger.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean delayErrors, int maxConcurrency) Returns anObservable
that emits items based on applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then merging those returnedObservableSource
s and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize) Returns anObservable
that emits items based on applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then merging those returnedObservableSource
s and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int maxConcurrency) Returns anObservable
that emits items based on applying a function that you supply to each item emitted by the currentObservable
, where that function returns anObservableSource
, and then merging those returnedObservableSource
s and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> onNextMapper, @NonNull Function<? super Throwable, ? extends ObservableSource<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends ObservableSource<? extends @NonNull R>> onCompleteSupplier) Returns anObservable
that applies a function to each item emitted or notification raised by the currentObservable
and then flattens theObservableSource
s returned from these functions and emits the resulting items.final <@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> onNextMapper, @NonNull Function<Throwable, ? extends ObservableSource<? extends @NonNull R>> onErrorMapper, @NonNull Supplier<? extends ObservableSource<? extends @NonNull R>> onCompleteSupplier, int maxConcurrency) Returns anObservable
that applies a function to each item emitted or notification raised by the currentObservable
and then flattens theObservableSource
s returned from these functions and emits the resulting items, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner) Returns anObservable
that emits the results of a specified function to the pair of values emitted by the currentObservable
and the mapped innerObservableSource
.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, boolean delayErrors) Returns anObservable
that emits the results of a specified function to the pair of values emitted by the currentObservable
and the mapped innerObservableSource
.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, boolean delayErrors, int maxConcurrency) Returns anObservable
that emits the results of a specified function to the pair of values emitted by the currentObservable
and the mapped innerObservableSource
, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, boolean delayErrors, int maxConcurrency, int bufferSize) Returns anObservable
that emits the results of a specified function to the pair of values emitted by the currentObservable
and the mapped innerObservableSource
, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.flatMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner, int maxConcurrency) Returns anObservable
that emits the results of a specified function to the pair of values emitted by the currentObservable
and the mapped innerObservableSource
, while limiting the maximum number of concurrent subscriptions to theseObservableSource
s.Single.flatMap
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Returns aSingle
that is based on applying a specified function to the item emitted by the currentSingle
, where that function returns aSingleSource
.Single.flatMap
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> onSuccessMapper, @NonNull Function<? super Throwable, ? extends SingleSource<? extends @NonNull R>> onErrorMapper) Maps theonSuccess
oronError
signals of the currentSingle
into aSingleSource
and emits thatSingleSource
's signals.Single.flatMap
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner) Returns aSingle
that emits the results of a specified function to the pair of values emitted by the currentSingle
and a specified mappedSingleSource
.final @NonNull Completable
Flowable.flatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Maps each element of the upstreamFlowable
intoCompletableSource
s, subscribes to them and waits until the upstream and allCompletableSource
s complete.final @NonNull Completable
Flowable.flatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean delayErrors, int maxConcurrency) Maps each element of the upstreamFlowable
intoCompletableSource
s, subscribes to them and waits until the upstream and allCompletableSource
s complete, optionally delaying all errors.final @NonNull Completable
Maybe.flatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Returns aCompletable
that completes based on applying a specified function to the item emitted by the currentMaybe
, where that function returns aCompletable
.final @NonNull Completable
Observable.flatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Maps each element of the currentObservable
intoCompletableSource
s, subscribes to them and waits until the upstream and allCompletableSource
s complete.final @NonNull Completable
Observable.flatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper, boolean delayErrors) Maps each element of the currentObservable
intoCompletableSource
s, subscribes to them and waits until the upstream and allCompletableSource
s complete, optionally delaying all errors.final @NonNull Completable
Single.flatMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Returns aCompletable
that completes based on applying a specified function to the item emitted by the currentSingle
, where that function returns aCompletableSource
.Flowable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) Flowable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper, int bufferSize) Flowable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull V> combiner) MergesIterable
s generated by a mapperFunction
for each individual item emitted by the currentFlowable
into a singleFlowable
sequence where the resulting items will be the combination of the original item and each inner item of the respectiveIterable
as returned by theresultSelector
BiFunction
.Flowable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull V> combiner, int prefetch) MergesIterable
s generated by a mapperFunction
for each individual item emitted by the currentFlowable
into a singleFlowable
sequence where the resulting items will be the combination of the original item and each inner item of the respectiveIterable
as returned by theresultSelector
BiFunction
.final <@NonNull U>
@NonNull Observable<U> Observable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) final <@NonNull U,
@NonNull V>
@NonNull Observable<V> Observable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull V> combiner) MergesIterable
s generated by a mapperFunction
for each individual item emitted by the currentObservable
into a singleObservable
sequence where the resulting items will be the combination of the original item and each inner item of the respectiveIterable
as returned by theresultSelector
BiFunction
.Flowable.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps each element of the upstreamFlowable
intoMaybeSource
s, subscribes to all of them and merges theironSuccess
values, in no particular order, into a singleFlowable
sequence.Flowable.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean delayErrors, int maxConcurrency) Maps each element of the upstreamFlowable
intoMaybeSource
s, subscribes to at mostmaxConcurrency
MaybeSource
s at a time and merges theironSuccess
values, in no particular order, into a singleFlowable
sequence, optionally delaying all errors.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps each element of the currentObservable
intoMaybeSource
s, subscribes to all of them and merges theironSuccess
values, in no particular order, into a singleObservable
sequence.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper, boolean delayErrors) Maps each element of the currentObservable
intoMaybeSource
s, subscribes to them and merges theironSuccess
values, in no particular order, into a singleObservable
sequence, optionally delaying all errors.Single.flatMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Returns aMaybe
that is based on applying a specified function to the item emitted by the currentSingle
, where that function returns aMaybeSource
.final <@NonNull R>
@NonNull Observable<R> Maybe.flatMapObservable
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Returns anObservable
that is based on applying a specified function to the item emitted by the currentMaybe
, where that function returns anObservableSource
.final <@NonNull R>
@NonNull Observable<R> Single.flatMapObservable
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Returns anObservable
that is based on applying a specified function to the item emitted by the currentSingle
, where that function returns anObservableSource
.Maybe.flatMapPublisher
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Returns aFlowable
that emits items based on applying a specified function to the item emitted by the currentMaybe
, where that function returns aPublisher
.Single.flatMapPublisher
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Returns aFlowable
that emits items based on applying a specified function to the item emitted by the currentSingle
, where that function returns aPublisher
.Flowable.flatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Maps each element of the upstreamFlowable
intoSingleSource
s, subscribes to all of them and merges theironSuccess
values, in no particular order, into a singleFlowable
sequence.Flowable.flatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, boolean delayErrors, int maxConcurrency) Maps each element of the upstreamFlowable
intoSingleSource
s, subscribes to at mostmaxConcurrency
SingleSource
s at a time and merges theironSuccess
values, in no particular order, into a singleFlowable
sequence, optionally delaying all errors.Maybe.flatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Returns aMaybe
based on applying a specified function to the item emitted by the currentMaybe
, where that function returns aSingle
.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Maps each element of the currentObservable
intoSingleSource
s, subscribes to all of them and merges theironSuccess
values, in no particular order, into a singleObservable
sequence.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper, boolean delayErrors) Maps each element of the currentObservable
intoSingleSource
s, subscribes to them and merges theironSuccess
values, in no particular order, into a singleObservable
sequence, optionally delaying all errors.Flowable.flatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps each upstream item into aStream
and emits theStream
's items to the downstream in a sequential fashion.Flowable.flatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper, int prefetch) Maps each upstream item into aStream
and emits theStream
's items to the downstream in a sequential fashion.final <@NonNull R>
@NonNull Observable<R> Observable.flatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps each upstream item into aStream
and emits theStream
's items to the downstream in a sequential fashion.Maybe.flattenAsFlowable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) Single.flattenAsFlowable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) final <@NonNull U>
@NonNull Observable<U> Maybe.flattenAsObservable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) Maps the success value of the currentMaybe
into anIterable
and emits its items as anObservable
sequence.final <@NonNull U>
@NonNull Observable<U> Single.flattenAsObservable
(@NonNull Function<@NonNull ? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) Maps the success value of the currentSingle
into anIterable
and emits its items as anObservable
sequence.Maybe.flattenStreamAsFlowable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Single.flattenStreamAsFlowable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) final <@NonNull R>
@NonNull Observable<R> Maybe.flattenStreamAsObservable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps the upstream succecss value into a JavaStream
and emits its items to the downstream consumer as anObservable
.final <@NonNull R>
@NonNull Observable<R> Single.flattenStreamAsObservable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps the upstream succecss value into a JavaStream
and emits its items to the downstream consumer as anObservable
.final <@NonNull K>
@NonNull Flowable<GroupedFlowable<K, T>> Groups the items emitted by the currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s.final <@NonNull K>
@NonNull Flowable<GroupedFlowable<K, T>> Flowable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, boolean delayError) Groups the items emitted by the currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s.final <@NonNull K,
@NonNull V>
@NonNull Flowable<GroupedFlowable<K, V>> Flowable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector) Groups the items emitted by the currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s.final <@NonNull K,
@NonNull V>
@NonNull Flowable<GroupedFlowable<K, V>> Flowable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, boolean delayError) Groups the items emitted by the currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s.final <@NonNull K,
@NonNull V>
@NonNull Flowable<GroupedFlowable<K, V>> Flowable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, boolean delayError, int bufferSize) Groups the items emitted by the currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s.final <@NonNull K,
@NonNull V>
@NonNull Flowable<GroupedFlowable<K, V>> Flowable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, boolean delayError, int bufferSize, @NonNull Function<? super Consumer<Object>, ? extends Map<@NonNull K, Object>> evictingMapFactory) Groups the items emitted by the currentFlowable
according to a specified criterion, and emits these grouped items asGroupedFlowable
s.final <@NonNull K>
@NonNull Observable<GroupedObservable<K, T>> Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K>
@NonNull Observable<GroupedObservable<K, T>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, boolean delayError) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K,
@NonNull V>
@NonNull Observable<GroupedObservable<K, V>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, boolean delayError) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K,
@NonNull V>
@NonNull Observable<GroupedObservable<K, V>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, boolean delayError, int bufferSize) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.final <@NonNull K,
@NonNull V>
@NonNull Observable<GroupedObservable<K, V>> Observable.groupBy
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, Function<? super @NonNull T, ? extends @NonNull V> valueSelector) Groups the items emitted by the currentObservable
according to a specified criterion, and emits these grouped items asGroupedObservable
s.Flowable.groupJoin
(@NonNull org.reactivestreams.Publisher<? extends @NonNull TRight> other, @NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<@NonNull TLeftEnd>> leftEnd, @NonNull Function<? super @NonNull TRight, @NonNull ? extends org.reactivestreams.Publisher<@NonNull TRightEnd>> rightEnd, @NonNull BiFunction<? super @NonNull T, ? super Flowable<@NonNull TRight>, ? extends @NonNull R> resultSelector) Returns aFlowable
that correlates twoPublisher
s when they overlap in time and groups the results.Observable.groupJoin
(@NonNull ObservableSource<? extends @NonNull TRight> other, @NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull TLeftEnd>> leftEnd, @NonNull Function<? super @NonNull TRight, ? extends ObservableSource<@NonNull TRightEnd>> rightEnd, @NonNull BiFunction<? super @NonNull T, ? super Observable<@NonNull TRight>, ? extends @NonNull R> resultSelector) Returns anObservable
that correlates twoObservableSource
s when they overlap in time and groups the results.Flowable.join
(@NonNull org.reactivestreams.Publisher<? extends @NonNull TRight> other, @NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<@NonNull TLeftEnd>> leftEnd, @NonNull Function<? super @NonNull TRight, @NonNull ? extends org.reactivestreams.Publisher<@NonNull TRightEnd>> rightEnd, @NonNull BiFunction<? super @NonNull T, ? super @NonNull TRight, ? extends @NonNull R> resultSelector) Correlates the items emitted by twoPublisher
s based on overlapping durations.Observable.join
(@NonNull ObservableSource<? extends @NonNull TRight> other, @NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull TLeftEnd>> leftEnd, @NonNull Function<? super @NonNull TRight, ? extends ObservableSource<@NonNull TRightEnd>> rightEnd, @NonNull BiFunction<? super @NonNull T, ? super @NonNull TRight, ? extends @NonNull R> resultSelector) Correlates the items emitted by twoObservableSource
s based on overlapping durations.Returns aFlowable
that applies a specified function to each item emitted by the currentFlowable
and emits the results of these function applications.Returns aMaybe
that applies a specified function to the item emitted by the currentMaybe
and emits the result of this function application.final <@NonNull R>
@NonNull Observable<R> Returns anObservable
that applies a specified function to each item emitted by the currentObservable
and emits the results of these function applications.Returns aSingle
that applies a specified function to the item emitted by the currentSingle
and emits the result of this function application.Flowable.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper) Maps each upstream value into anOptional
and emits the contained item if not empty.Maybe.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper) Maps the upstream success value into anOptional
and emits the contained item if not empty.final <@NonNull R>
@NonNull Observable<R> Observable.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper) Maps each upstream value into anOptional
and emits the contained item if not empty.Single.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper) final @NonNull Completable
Completable.onErrorResumeNext
(@NonNull Function<? super Throwable, ? extends CompletableSource> fallbackSupplier) Returns aCompletable
instance that when encounters an error from thisCompletable
, calls the specifiedmapper
Function
that returns aCompletableSource
instance for it and resumes the execution with it.Flowable.onErrorResumeNext
(@NonNull Function<? super Throwable, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> fallbackSupplier) Resumes the flow with aPublisher
returned for the failureThrowable
of the currentFlowable
by a function instead of signaling the error viaonError
.Maybe.onErrorResumeNext
(@NonNull Function<? super Throwable, ? extends MaybeSource<? extends @NonNull T>> fallbackSupplier) Resumes the flow with aMaybeSource
returned for the failureThrowable
of the currentMaybe
by a function instead of signaling the error viaonError
.final @NonNull Observable
<T> Observable.onErrorResumeNext
(@NonNull Function<? super Throwable, ? extends ObservableSource<? extends @NonNull T>> fallbackSupplier) Resumes the flow with anObservableSource
returned for the failureThrowable
of the currentObservable
by a function instead of signaling the error viaonError
.Single.onErrorResumeNext
(@NonNull Function<? super Throwable, ? extends SingleSource<? extends @NonNull T>> fallbackSupplier) Resumes the flow with aSingleSource
returned for the failureThrowable
of the currentSingle
by a function instead of signaling the error viaonError
.Completable.onErrorReturn
(@NonNull Function<? super Throwable, ? extends @NonNull T> itemSupplier) Ends the flow with a success item returned by a function for theThrowable
error signaled by the currentCompletable
instead of signaling the error viaonError
.Ends the flow with a last item returned by a function for theThrowable
error signaled by the currentFlowable
instead of signaling the error viaonError
.Ends the flow with a success item returned by a function for theThrowable
error signaled by the currentMaybe
instead of signaling the error viaonError
.final @NonNull Observable
<T> Ends the flow with a last item returned by a function for theThrowable
error signaled by the currentObservable
instead of signaling the error viaonError
.Ends the flow with a success item returned by a function for theThrowable
error signaled by the currentSingle
instead of signaling the error viaonError
.Flowable.publish
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> selector, int prefetch) Returns aFlowable
that emits the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the underlying sequence.Flowable.publish
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector) Returns aFlowable
that emits the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the underlying sequence.final <@NonNull R>
@NonNull Observable<R> Observable.publish
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector) Returns anObservable
that emits the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
sequence.final @NonNull Completable
Completable.repeatWhen
(@NonNull Function<? super Flowable<Object>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull ?>> handler) Returns aCompletable
instance that repeats when thePublisher
returned by the handlerFunction
emits an item or completes when thisPublisher
emits anonComplete
event.Flowable.repeatWhen
(@NonNull Function<? super Flowable<Object>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull ?>> handler) Returns aFlowable
that emits the same values as the currentFlowable
with the exception of anonComplete
.Maybe.repeatWhen
(@NonNull Function<? super Flowable<Object>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull ?>> handler) Returns aFlowable
that emits the same values as the currentMaybe
with the exception of anonComplete
.final @NonNull Observable
<T> Observable.repeatWhen
(@NonNull Function<? super Observable<Object>, ? extends ObservableSource<?>> handler) Returns anObservable
that emits the same values as the currentObservable
with the exception of anonComplete
.Single.repeatWhen
(@NonNull Function<? super Flowable<Object>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull ?>> handler) Re-subscribes to the currentSingle
if thePublisher
returned by the handler function signals a value in response to a value signaled through theFlowable
the handler receives.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector) Returns aFlowable
that emits items that are the results of invoking a specified selector on the items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, int bufferSize) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replayingbufferSize
notifications.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, int bufferSize, boolean eagerTruncate) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replayingbufferSize
notifications.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, int bufferSize, long time, @NonNull TimeUnit unit) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replaying no more thanbufferSize
items that were emitted within a specified time window.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replaying no more thanbufferSize
items that were emitted within a specified time window.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replaying no more thanbufferSize
items that were emitted within a specified time window.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, long time, @NonNull TimeUnit unit) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replaying all items that were emitted within a specified time window.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replaying all items that were emitted within a specified time window.Flowable.replay
(@NonNull Function<? super Flowable<@NonNull T>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull R>> selector, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns aFlowable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableFlowable
that shares a single subscription to the currentFlowable
, replaying all items that were emitted within a specified time window.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector) Returns anObservable
that emits items that are the results of invoking a specified selector on the items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, int bufferSize) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replayingbufferSize
notifications.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, int bufferSize, boolean eagerTruncate) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replayingbufferSize
notifications.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, int bufferSize, long time, @NonNull TimeUnit unit) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replaying no more thanbufferSize
items that were emitted within a specified time window.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replaying no more thanbufferSize
items that were emitted within a specified time window.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, int bufferSize, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replaying no more thanbufferSize
items that were emitted within a specified time window.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, long time, @NonNull TimeUnit unit) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replaying all items that were emitted within a specified time window.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replaying all items that were emitted within a specified time window.final <@NonNull R>
@NonNull Observable<R> Observable.replay
(@NonNull Function<? super Observable<@NonNull T>, ? extends ObservableSource<@NonNull R>> selector, long time, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean eagerTruncate) Returns anObservable
that emits items that are the results of invoking a specified selector on items emitted by aConnectableObservable
that shares a single subscription to the currentObservable
, replaying all items that were emitted within a specified time window.final @NonNull Completable
Completable.retryWhen
(@NonNull Function<? super Flowable<Throwable>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull ?>> handler) Returns aCompletable
which given aPublisher
and when thisCompletable
emits an error, delivers that error through aFlowable
and thePublisher
should signal a value indicating a retry in response or a terminal event indicating a termination.Flowable.retryWhen
(@NonNull Function<? super Flowable<Throwable>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull ?>> handler) Returns aFlowable
that emits the same values as the currentFlowable
with the exception of anonError
.Maybe.retryWhen
(@NonNull Function<? super Flowable<Throwable>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull ?>> handler) Returns aMaybe
that emits the same values as the currentMaybe
with the exception of anonError
.final @NonNull Observable
<T> Observable.retryWhen
(@NonNull Function<? super Observable<Throwable>, ? extends ObservableSource<?>> handler) Returns anObservable
that emits the same values as the currentObservable
with the exception of anonError
.Single.retryWhen
(@NonNull Function<? super Flowable<Throwable>, @NonNull ? extends org.reactivestreams.Publisher<@NonNull ?>> handler) Re-subscribes to the currentSingle
if and when thePublisher
returned by the handler function signals a value.Flowable.switchMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Returns a newFlowable
by applying a function that you supply to each item emitted by the currentFlowable
that returns aPublisher
, and then emitting the items emitted by the most recently emitted of thesePublisher
s.Flowable.switchMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int bufferSize) Returns a newFlowable
by applying a function that you supply to each item emitted by the currentFlowable
that returns aPublisher
, and then emitting the items emitted by the most recently emitted of thesePublisher
s.final <@NonNull R>
@NonNull Observable<R> Observable.switchMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns anObservableSource
, and then emitting the items emitted by the most recently emitted of theseObservableSource
s.final <@NonNull R>
@NonNull Observable<R> Observable.switchMap
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int bufferSize) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns anObservableSource
, and then emitting the items emitted by the most recently emitted of theseObservableSource
s.(package private) <R> Flowable
<R> Flowable.switchMap0
(Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends R>> mapper, int bufferSize, boolean delayError) final @NonNull Completable
Flowable.switchMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Maps the upstream values intoCompletableSource
s, subscribes to the newer one while disposing the subscription to the previousCompletableSource
, thus keeping at most one activeCompletableSource
running.final @NonNull Completable
Observable.switchMapCompletable
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Maps the items of the currentObservable
intoCompletableSource
s, subscribes to the newer one while disposing the subscription to the previousCompletableSource
, thus keeping at most one activeCompletableSource
running.final @NonNull Completable
Flowable.switchMapCompletableDelayError
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Maps the upstream values intoCompletableSource
s, subscribes to the newer one while disposing the subscription to the previousCompletableSource
, thus keeping at most one activeCompletableSource
running and delaying any main or inner errors until all of them terminate.final @NonNull Completable
Observable.switchMapCompletableDelayError
(@NonNull Function<? super @NonNull T, ? extends CompletableSource> mapper) Maps the upstream values intoCompletableSource
s, subscribes to the newer one while disposing the subscription to the previousCompletableSource
, thus keeping at most one activeCompletableSource
running and delaying any main or inner errors until all of them terminate.Flowable.switchMapDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Returns a newFlowable
by applying a function that you supply to each item emitted by the currentFlowable
that returns aPublisher
, and then emitting the items emitted by the most recently emitted of thesePublisher
s and delays any error until allPublisher
s terminate.Flowable.switchMapDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int bufferSize) Returns a newFlowable
by applying a function that you supply to each item emitted by the currentFlowable
that returns aPublisher
, and then emitting the items emitted by the most recently emitted of thesePublisher
s and delays any error until allPublisher
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns anObservableSource
, and then emitting the items emitted by the most recently emitted of theseObservableSource
s and delays any error until allObservableSource
s terminate.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapDelayError
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<? extends @NonNull R>> mapper, int bufferSize) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns anObservableSource
, and then emitting the items emitted by the most recently emitted of theseObservableSource
s and delays any error until allObservableSource
s terminate.Flowable.switchMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if available while failing immediately if thisFlowable
or any of the active innerMaybeSource
s fail.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapMaybe
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the items of the currentObservable
intoMaybeSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if available while failing immediately if the currentObservable
or any of the active innerMaybeSource
s fail.Flowable.switchMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if available, delaying errors from thisFlowable
or the innerMaybeSource
s until all terminate.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapMaybeDelayError
(@NonNull Function<? super @NonNull T, ? extends MaybeSource<? extends @NonNull R>> mapper) Maps the upstream items intoMaybeSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one if available, delaying errors from the currentObservable
or the innerMaybeSource
s until all terminate.Flowable.switchMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Maps the upstream items intoSingleSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one while failing immediately if thisFlowable
or any of the active innerSingleSource
s fail.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapSingle
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns aSingleSource
, and then emitting the item emitted by the most recently emitted of theseSingleSource
s.Flowable.switchMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Maps the upstream items intoSingleSource
s and switches (subscribes) to the newer ones while disposing the older ones (and ignoring their signals) and emits the latest success value of the current one, delaying errors from thisFlowable
or the innerSingleSource
s until all terminate.final <@NonNull R>
@NonNull Observable<R> Observable.switchMapSingleDelayError
(@NonNull Function<? super @NonNull T, ? extends SingleSource<? extends @NonNull R>> mapper) Returns a newObservable
by applying a function that you supply to each item emitted by the currentObservable
that returns aSingleSource
, and then emitting the item emitted by the most recently emitted of theseSingleSource
s and delays any error until allSingleSource
s terminate.Flowable.timeout
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<@NonNull V>> itemTimeoutIndicator) Returns aFlowable
that mirrors the currentFlowable
, but notifiesSubscriber
s of aTimeoutException
if an item emitted by the currentFlowable
doesn't arrive within a window of time after the emission of the previous item, where that period of time is measured by aPublisher
that is a function of the previous item.Flowable.timeout
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<@NonNull V>> itemTimeoutIndicator, @NonNull org.reactivestreams.Publisher<? extends @NonNull T> fallback) Returns aFlowable
that mirrors the currentFlowable
, but that switches to a fallbackPublisher
if an item emitted by the currentFlowable
doesn't arrive within a window of time after the emission of the previous item, where that period of time is measured by aPublisher
that is a function of the previous item.Flowable.timeout
(@NonNull org.reactivestreams.Publisher<@NonNull U> firstTimeoutIndicator, @NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<@NonNull V>> itemTimeoutIndicator) Returns aFlowable
that mirrors the currentFlowable
, but notifiesSubscriber
s of aTimeoutException
if either the first item emitted by the currentFlowable
or any subsequent item doesn't arrive within time windows defined by otherPublisher
s.Flowable.timeout
(@NonNull org.reactivestreams.Publisher<@NonNull U> firstTimeoutIndicator, @NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<@NonNull V>> itemTimeoutIndicator, @NonNull org.reactivestreams.Publisher<? extends @NonNull T> fallback) Returns aFlowable
that mirrors the currentFlowable
, but switches to a fallbackPublisher
if either the first item emitted by the currentFlowable
or any subsequent item doesn't arrive within time windows defined by otherPublisher
s.final <@NonNull U,
@NonNull V>
@NonNull Observable<T> Observable.timeout
(@NonNull ObservableSource<@NonNull U> firstTimeoutIndicator, @NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull V>> itemTimeoutIndicator) Returns anObservable
that mirrors the currentObservable
, but notifies observers of aTimeoutException
if either the first item emitted by the currentObservable
or any subsequent item doesn't arrive within time windows defined by indicatorObservableSource
s.final <@NonNull U,
@NonNull V>
@NonNull Observable<T> Observable.timeout
(@NonNull ObservableSource<@NonNull U> firstTimeoutIndicator, @NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull V>> itemTimeoutIndicator, @NonNull ObservableSource<? extends @NonNull T> fallback) Returns anObservable
that mirrors the currentObservable
, but switches to a fallbackObservableSource
if either the first item emitted by the currentObservable
or any subsequent item doesn't arrive within time windows defined by indicatorObservableSource
s.final <@NonNull V>
@NonNull Observable<T> Observable.timeout
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull V>> itemTimeoutIndicator) Returns anObservable
that mirrors the currentObservable
, but notifies observers of aTimeoutException
if an item emitted by the currentObservable
doesn't arrive within a window of time after the emission of the previous item, where that period of time is measured by anObservableSource
that is a function of the previous item.final <@NonNull V>
@NonNull Observable<T> Observable.timeout
(@NonNull Function<? super @NonNull T, ? extends ObservableSource<@NonNull V>> itemTimeoutIndicator, @NonNull ObservableSource<? extends @NonNull T> fallback) Returns anObservable
that mirrors the currentObservable
, but that switches to a fallbackObservableSource
if an item emitted by the currentObservable
doesn't arrive within a window of time after the emission of the previous item, where that period of time is measured by anObservableSource
that is a function of the previous item.Flowable.timeout0
(org.reactivestreams.Publisher<@NonNull U> firstTimeoutIndicator, Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<@NonNull V>> itemTimeoutIndicator, org.reactivestreams.Publisher<? extends @NonNull T> fallback) private <U,
V> @NonNull Observable <T> Observable.timeout0
(@NonNull ObservableSource<U> firstTimeoutIndicator, @NonNull Function<? super @NonNull T, ? extends ObservableSource<V>> itemTimeoutIndicator, @Nullable ObservableSource<? extends @NonNull T> fallback) Flowable.toMap
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector) Flowable.toMap
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<? extends Map<@NonNull K, @NonNull V>> mapSupplier) Observable.toMap
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector) Observable.toMap
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<? extends Map<@NonNull K, @NonNull V>> mapSupplier) Flowable.toMultimap
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector) Flowable.toMultimap
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<? extends Map<@NonNull K, Collection<@NonNull V>>> mapSupplier, @NonNull Function<? super @NonNull K, ? extends Collection<? super @NonNull V>> collectionFactory) Flowable.toMultimap
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<Map<@NonNull K, Collection<@NonNull V>>> mapSupplier) Observable.toMultimap
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<? extends Map<@NonNull K, Collection<@NonNull V>>> mapSupplier, @NonNull Function<? super @NonNull K, ? extends Collection<? super @NonNull V>> collectionFactory) Returns aSingle
that emits a singleMap
(subclass), returned by a specifiedmapFactory
function, that contains a customCollection
of values, extracted by a specifiedvalueSelector
function from items emitted by the current and finiteObservable
, and keyed by thekeySelector
function.Observable.toMultimap
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, @NonNull Function<? super @NonNull T, ? extends @NonNull V> valueSelector, @NonNull Supplier<Map<@NonNull K, Collection<@NonNull V>>> mapSupplier) Observable.toMultimap
(@NonNull Function<? super @NonNull T, ? extends @NonNull K> keySelector, Function<? super @NonNull T, ? extends @NonNull V> valueSelector) static <@NonNull R>
@NonNull CompletableCompletable.using
(@NonNull Supplier<@NonNull R> resourceSupplier, @NonNull Function<? super @NonNull R, ? extends CompletableSource> sourceSupplier, @NonNull Consumer<? super @NonNull R> resourceCleanup) Returns aCompletable
instance which manages a resource along with a customCompletableSource
instance while the subscription is active.static <@NonNull R>
@NonNull CompletableCompletable.using
(@NonNull Supplier<@NonNull R> resourceSupplier, @NonNull Function<? super @NonNull R, ? extends CompletableSource> sourceSupplier, @NonNull Consumer<? super @NonNull R> resourceCleanup, boolean eager) Returns aCompletable
instance which manages a resource along with a customCompletableSource
instance while the subscription is active and performs eager or lazy resource disposition.Flowable.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup) Constructs aFlowable
that creates a dependent resource object, aPublisher
with that resource and calls the providedresourceDisposer
function if this inner source terminates or the downstream cancels the flow.Flowable.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup, boolean eager) Constructs aFlowable
that creates a dependent resource object, aPublisher
with that resource and calls the providedresourceDisposer
function if this inner source terminates or the downstream disposes the flow; doing it before these end-states have been reached ifeager == true
, after otherwise.Maybe.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends MaybeSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup) Constructs aMaybe
that creates a dependent resource object which is disposed of when the generatedMaybeSource
terminates or the downstream calls dispose().Maybe.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends MaybeSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup, boolean eager) Constructs aMaybe
that creates a dependent resource object which is disposed first ({code eager == true}) when the generatedMaybeSource
terminates or the downstream disposes; or after ({code eager == false}).static <@NonNull T,
@NonNull D>
@NonNull Observable<T> Observable.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends ObservableSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup) Constructs anObservable
that creates a dependent resource object, anObservableSource
with that resource and calls the providedresourceDisposer
function if this inner source terminates or the downstream disposes the flow.static <@NonNull T,
@NonNull D>
@NonNull Observable<T> Observable.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends ObservableSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup, boolean eager) Constructs anObservable
that creates a dependent resource object, anObservableSource
with that resource and calls the provideddisposer
function if this inner source terminates or the downstream disposes the flow; doing it before these end-states have been reached ifeager == true
, after otherwise.Single.using
(@NonNull Supplier<@NonNull U> resourceSupplier, @NonNull Function<? super @NonNull U, ? extends SingleSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull U> resourceCleanup) Allows using and disposing a resource while running aSingleSource
instance generated from that resource (similar to a try-with-resources).Single.using
(@NonNull Supplier<@NonNull U> resourceSupplier, @NonNull Function<? super @NonNull U, ? extends SingleSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull U> resourceCleanup, boolean eager) Allows using and disposing a resource while running aSingleSource
instance generated from that resource (similar to a try-with-resources).<S extends Scheduler & Disposable>
SScheduler.when
(@NonNull Function<Flowable<Flowable<Completable>>, Completable> combine) Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.Flowable.window
(@NonNull org.reactivestreams.Publisher<@NonNull U> openingIndicator, @NonNull Function<? super @NonNull U, @NonNull ? extends org.reactivestreams.Publisher<@NonNull V>> closingIndicator) Returns aFlowable
that emits windows of items it collects from the currentFlowable
.Flowable.window
(@NonNull org.reactivestreams.Publisher<@NonNull U> openingIndicator, @NonNull Function<? super @NonNull U, @NonNull ? extends org.reactivestreams.Publisher<@NonNull V>> closingIndicator, int bufferSize) Returns aFlowable
that emits windows of items it collects from the currentFlowable
.final <@NonNull U,
@NonNull V>
@NonNull Observable<Observable<T>> Observable.window
(@NonNull ObservableSource<@NonNull U> openingIndicator, @NonNull Function<? super @NonNull U, ? extends ObservableSource<@NonNull V>> closingIndicator) Returns anObservable
that emits windows of items it collects from the currentObservable
.final <@NonNull U,
@NonNull V>
@NonNull Observable<Observable<T>> Observable.window
(@NonNull ObservableSource<@NonNull U> openingIndicator, @NonNull Function<? super @NonNull U, ? extends ObservableSource<@NonNull V>> closingIndicator, int bufferSize) Returns anObservable
that emits windows of items it collects from the currentObservable
.Flowable.withLatestFrom
(@NonNull Iterable<@NonNull ? extends org.reactivestreams.Publisher<@NonNull ?>> others, @NonNull Function<? super Object[], @NonNull R> combiner) Combines the value emission from the currentFlowable
with the latest emissions from the otherPublisher
s via a function to produce the output item.Flowable.withLatestFrom
(@NonNull org.reactivestreams.Publisher<@NonNull ?>[] others, @NonNull Function<? super Object[], @NonNull R> combiner) Combines the value emission from the currentFlowable
with the latest emissions from the otherPublisher
s via a function to produce the output item.final <@NonNull R>
@NonNull Observable<R> Observable.withLatestFrom
(@NonNull ObservableSource<?>[] others, @NonNull Function<? super Object[], @NonNull R> combiner) Combines the value emission from the currentObservable
with the latest emissions from the otherObservableSource
s via a function to produce the output item.final <@NonNull R>
@NonNull Observable<R> Observable.withLatestFrom
(@NonNull Iterable<@NonNull ? extends ObservableSource<?>> others, @NonNull Function<? super Object[], @NonNull R> combiner) Combines the value emission from the currentObservable
with the latest emissions from the otherObservableSource
s via a function to produce the output item.Flowable.zip
(@NonNull Iterable<@NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> zipper) Returns aFlowable
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by anIterable
of otherPublisher
s.Flowable.zip
(@NonNull Iterable<@NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> zipper, boolean delayError, int bufferSize) Returns aFlowable
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by anIterable
of otherPublisher
s.Maybe.zip
(@NonNull Iterable<@NonNull ? extends MaybeSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> zipper) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by anIterable
of otherMaybeSource
s.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> zipper) Returns anObservable
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by anIterable
of otherObservableSource
s.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull Iterable<@NonNull ? extends ObservableSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> zipper, boolean delayError, int bufferSize) Returns anObservable
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by anIterable
of otherObservableSource
s.Single.zip
(@NonNull Iterable<@NonNull ? extends SingleSource<? extends @NonNull T>> sources, @NonNull Function<? super Object[], ? extends @NonNull R> zipper) Waits until allSingleSource
sources provided by theIterable
sequence signal a success value and calls a zipper function with an array of these values to return a result to be emitted to the downstream.Flowable.zipArray
(@NonNull Function<? super Object[], ? extends @NonNull R> zipper, boolean delayError, int bufferSize, @NonNull org.reactivestreams.Publisher<? extends @NonNull T>... sources) Returns aFlowable
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by an array of otherPublisher
s.Maybe.zipArray
(@NonNull Function<? super Object[], ? extends @NonNull R> zipper, @NonNull MaybeSource<? extends @NonNull T>... sources) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by an array of otherMaybeSource
s.static <@NonNull T,
@NonNull R>
@NonNull Observable<R> Observable.zipArray
(@NonNull Function<? super Object[], ? extends @NonNull R> zipper, boolean delayError, int bufferSize, @NonNull ObservableSource<? extends @NonNull T>... sources) Returns anObservable
that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by an array of otherObservableSource
s.Single.zipArray
(@NonNull Function<? super Object[], ? extends @NonNull R> zipper, @NonNull SingleSource<? extends @NonNull T>... sources) Waits until allSingleSource
sources provided via an array signal a success value and calls a zipper function with an array of these values to return a result to be emitted to downstream. -
Uses of Function in io.reactivex.rxjava3.internal.functions
Classes in io.reactivex.rxjava3.internal.functions that implement FunctionModifier and TypeClassDescription(package private) static final class
Functions.Array2Func<T1,
T2, R> (package private) static final class
Functions.Array3Func<T1,
T2, T3, R> (package private) static final class
Functions.Array4Func<T1,
T2, T3, T4, R> (package private) static final class
Functions.Array5Func<T1,
T2, T3, T4, T5, R> (package private) static final class
Functions.Array6Func<T1,
T2, T3, T4, T5, T6, R> (package private) static final class
Functions.Array7Func<T1,
T2, T3, T4, T5, T6, T7, R> (package private) static final class
Functions.Array8Func<T1,
T2, T3, T4, T5, T6, T7, T8, R> (package private) static final class
Functions.Array9Func<T1,
T2, T3, T4, T5, T6, T7, T8, T9, R> (package private) static final class
(package private) static final class
(package private) static final class
Functions.JustValue<T,
U> (package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.functions declared as FunctionModifier and TypeFieldDescriptionprivate final Function
<? super K, ? extends Collection<? super V>> Functions.ToMultimapKeyValueSelector.collectionFactory
Functions.IDENTITY
A singleton identity function.Functions.ToMapKeySelector.keySelector
Functions.ToMapKeyValueSelector.keySelector
Functions.ToMultimapKeyValueSelector.keySelector
Functions.ToMapKeyValueSelector.valueSelector
Functions.ToMultimapKeyValueSelector.valueSelector
Methods in io.reactivex.rxjava3.internal.functions that return FunctionModifier and TypeMethodDescriptionFunctions.castFunction
(@NonNull Class<U> target) Returns a function that cast the incoming values via a Class object.Functions.identity()
Returns an identity function that simply returns its argument.Functions.justFunction
(U value) Returns a Function that ignores its parameter and returns the given value.Functions.listSorter
(Comparator<? super T> comparator) Functions.timestampWith
(TimeUnit unit, Scheduler scheduler) Functions.toFunction
(@NonNull BiFunction<? super T1, ? super T2, ? extends R> f) Functions.toFunction
(@NonNull Function3<T1, T2, T3, R> f) Functions.toFunction
(@NonNull Function4<T1, T2, T3, T4, R> f) Functions.toFunction
(@NonNull Function5<T1, T2, T3, T4, T5, R> f) Functions.toFunction
(@NonNull Function6<T1, T2, T3, T4, T5, T6, R> f) Functions.toFunction
(@NonNull Function7<T1, T2, T3, T4, T5, T6, T7, R> f) Functions.toFunction
(@NonNull Function8<T1, T2, T3, T4, T5, T6, T7, T8, R> f) Functions.toFunction
(@NonNull Function9<T1, T2, T3, T4, T5, T6, T7, T8, T9, R> f) Methods in io.reactivex.rxjava3.internal.functions with parameters of type FunctionModifier and TypeMethodDescriptionstatic <T,
K> BiConsumer <Map<K, T>, T> Functions.toMapKeySelector
(Function<? super T, ? extends K> keySelector) static <T,
K, V> BiConsumer <Map<K, V>, T> Functions.toMapKeyValueSelector
(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector) static <T,
K, V> BiConsumer <Map<K, Collection<V>>, T> Functions.toMultimapKeyValueSelector
(Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, Function<? super K, ? extends Collection<? super V>> collectionFactory) Constructors in io.reactivex.rxjava3.internal.functions with parameters of type FunctionModifierConstructorDescription(package private)
ToMapKeySelector
(Function<? super T, ? extends K> keySelector) (package private)
ToMapKeyValueSelector
(Function<? super T, ? extends V> valueSelector, Function<? super T, ? extends K> keySelector) (package private)
ToMultimapKeyValueSelector
(Function<? super K, ? extends Collection<? super V>> collectionFactory, Function<? super T, ? extends V> valueSelector, Function<? super T, ? extends K> keySelector) -
Uses of Function in io.reactivex.rxjava3.internal.jdk8
Fields in io.reactivex.rxjava3.internal.jdk8 declared as FunctionModifier and TypeFieldDescriptionFlowableFlatMapStream.FlatMapStreamSubscriber.mapper
FlowableFlatMapStream.mapper
FlowableMapOptional.MapOptionalConditionalSubscriber.mapper
FlowableMapOptional.MapOptionalSubscriber.mapper
FlowableMapOptional.mapper
MaybeFlattenStreamAsFlowable.FlattenStreamMultiObserver.mapper
MaybeFlattenStreamAsFlowable.mapper
MaybeFlattenStreamAsObservable.FlattenStreamMultiObserver.mapper
MaybeFlattenStreamAsObservable.mapper
MaybeMapOptional.MapOptionalMaybeObserver.mapper
MaybeMapOptional.mapper
ObservableFlatMapStream.FlatMapStreamObserver.mapper
ObservableFlatMapStream.mapper
ObservableMapOptional.MapOptionalObserver.mapper
ObservableMapOptional.mapper
ParallelFlatMapStream.mapper
ParallelMapOptional.mapper
ParallelMapOptional.ParallelMapConditionalSubscriber.mapper
ParallelMapOptional.ParallelMapSubscriber.mapper
ParallelMapTryOptional.mapper
ParallelMapTryOptional.ParallelMapTryConditionalSubscriber.mapper
ParallelMapTryOptional.ParallelMapTrySubscriber.mapper
SingleFlattenStreamAsFlowable.mapper
SingleFlattenStreamAsObservable.mapper
SingleMapOptional.MapOptionalSingleObserver.mapper
SingleMapOptional.mapper
Methods in io.reactivex.rxjava3.internal.jdk8 with parameters of type FunctionModifier and TypeMethodDescriptionstatic <T,
R> org.reactivestreams.Subscriber <T> FlowableFlatMapStream.subscribe
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends Stream<? extends R>> mapper, int prefetch) Create aSubscriber
with the given parameters.Constructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type FunctionModifierConstructorDescription(package private)
FlatMapStreamObserver
(Observer<? super R> downstream, Function<? super T, ? extends Stream<? extends R>> mapper) (package private)
FlatMapStreamSubscriber
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends Stream<? extends R>> mapper, int prefetch) (package private)
FlattenStreamMultiObserver
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends Stream<? extends R>> mapper) (package private)
FlattenStreamMultiObserver
(Observer<? super R> downstream, Function<? super T, ? extends Stream<? extends R>> mapper) FlowableFlatMapStream
(Flowable<T> source, Function<? super T, ? extends Stream<? extends R>> mapper, int prefetch) (package private)
MapOptionalConditionalSubscriber
(ConditionalSubscriber<? super R> downstream, Function<? super T, Optional<? extends R>> mapper) (package private)
MapOptionalMaybeObserver
(MaybeObserver<? super R> downstream, Function<? super T, Optional<? extends R>> mapper) (package private)
MapOptionalObserver
(Observer<? super R> downstream, Function<? super T, Optional<? extends R>> mapper) (package private)
MapOptionalSingleObserver
(MaybeObserver<? super R> downstream, Function<? super T, Optional<? extends R>> mapper) (package private)
MapOptionalSubscriber
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, Optional<? extends R>> mapper) MaybeFlattenStreamAsFlowable
(Maybe<T> source, Function<? super T, ? extends Stream<? extends R>> mapper) MaybeFlattenStreamAsObservable
(Maybe<T> source, Function<? super T, ? extends Stream<? extends R>> mapper) ObservableFlatMapStream
(Observable<T> source, Function<? super T, ? extends Stream<? extends R>> mapper) ObservableMapOptional
(Observable<T> source, Function<? super T, Optional<? extends R>> mapper) ParallelFlatMapStream
(ParallelFlowable<T> source, Function<? super T, ? extends Stream<? extends R>> mapper, int prefetch) (package private)
ParallelMapConditionalSubscriber
(ConditionalSubscriber<? super R> actual, Function<? super T, Optional<? extends R>> mapper) ParallelMapOptional
(ParallelFlowable<T> source, Function<? super T, Optional<? extends R>> mapper) (package private)
ParallelMapSubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, Optional<? extends R>> mapper) (package private)
ParallelMapTryConditionalSubscriber
(ConditionalSubscriber<? super R> actual, Function<? super T, Optional<? extends R>> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) ParallelMapTryOptional
(ParallelFlowable<T> source, Function<? super T, Optional<? extends R>> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelMapTrySubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, Optional<? extends R>> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) SingleFlattenStreamAsFlowable
(Single<T> source, Function<? super T, ? extends Stream<? extends R>> mapper) SingleFlattenStreamAsObservable
(Single<T> source, Function<? super T, ? extends Stream<? extends R>> mapper) -
Uses of Function in io.reactivex.rxjava3.internal.operators.completable
Fields in io.reactivex.rxjava3.internal.operators.completable declared as FunctionModifier and TypeFieldDescription(package private) final Function
<? super R, ? extends CompletableSource> CompletableUsing.completableFunction
(package private) final Function
<? super Throwable, ? extends CompletableSource> CompletableResumeNext.errorMapper
(package private) final Function
<? super Throwable, ? extends CompletableSource> CompletableResumeNext.ResumeNextObserver.errorMapper
CompletableOnErrorReturn.OnErrorReturnMaybeObserver.itemSupplier
CompletableOnErrorReturn.valueSupplier
Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type FunctionModifierConstructorDescriptionCompletableOnErrorReturn
(CompletableSource source, Function<? super Throwable, ? extends T> valueSupplier) CompletableResumeNext
(CompletableSource source, Function<? super Throwable, ? extends CompletableSource> errorMapper) CompletableUsing
(Supplier<R> resourceSupplier, Function<? super R, ? extends CompletableSource> completableFunction, Consumer<? super R> disposer, boolean eager) (package private)
OnErrorReturnMaybeObserver
(MaybeObserver<? super T> actual, Function<? super Throwable, ? extends T> itemSupplier) (package private)
ResumeNextObserver
(CompletableObserver observer, Function<? super Throwable, ? extends CompletableSource> errorMapper) -
Uses of Function in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement FunctionModifier and TypeClassDescription(package private) final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) final class
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as FunctionModifier and TypeFieldDescription(package private) final Function
<? super Open, ? extends org.reactivestreams.Publisher<? extends Close>> FlowableBufferBoundary.BufferBoundarySubscriber.bufferClose
(package private) final Function
<? super Open, ? extends org.reactivestreams.Publisher<? extends Close>> FlowableBufferBoundary.bufferClose
FlowableWindowBoundarySelector.closingIndicator
FlowableWindowBoundarySelector.WindowBoundaryMainSubscriber.closingIndicator
FlowableCombineLatest.CombineLatestCoordinator.combiner
FlowableCombineLatest.combiner
FlowableWithLatestFromMany.combiner
FlowableWithLatestFromMany.WithLatestFromSubscriber.combiner
FlowableDebounce.debounceSelector
FlowableDebounce.DebounceSubscriber.debounceSelector
(package private) final Function
<? super Flowable<Object>, ? extends org.reactivestreams.Publisher<?>> FlowableRepeatWhen.handler
(package private) final Function
<? super Flowable<Throwable>, ? extends org.reactivestreams.Publisher<?>> FlowableRetryWhen.handler
FlowableInternalHelper.ItemDelayFunction.itemDelay
FlowableTimeout.itemTimeoutIndicator
FlowableTimeout.TimeoutFallbackSubscriber.itemTimeoutIndicator
FlowableTimeout.TimeoutSubscriber.itemTimeoutIndicator
FlowableDistinct.DistinctSubscriber.keySelector
FlowableDistinct.keySelector
FlowableDistinctUntilChanged.DistinctUntilChangedConditionalSubscriber.keySelector
FlowableDistinctUntilChanged.DistinctUntilChangedSubscriber.keySelector
FlowableDistinctUntilChanged.keySelector
FlowableGroupBy.GroupBySubscriber.keySelector
FlowableGroupBy.keySelector
FlowableGroupJoin.GroupJoinSubscription.leftEnd
FlowableGroupJoin.leftEnd
FlowableJoin.JoinSubscription.leftEnd
FlowableJoin.leftEnd
FlowableGroupBy.mapFactory
FlowableConcatMap.BaseConcatMapSubscriber.mapper
FlowableConcatMap.mapper
FlowableConcatMapEager.ConcatMapEagerDelayErrorSubscriber.mapper
FlowableConcatMapEager.mapper
FlowableConcatMapEagerPublisher.mapper
FlowableConcatMapScheduler.BaseConcatMapSubscriber.mapper
FlowableConcatMapScheduler.mapper
FlowableFlatMap.mapper
FlowableFlatMap.MergeSubscriber.mapper
(package private) final Function
<? super T, ? extends CompletableSource> FlowableFlatMapCompletable.FlatMapCompletableMainSubscriber.mapper
(package private) final Function
<? super T, ? extends CompletableSource> FlowableFlatMapCompletable.mapper
(package private) final Function
<? super T, ? extends CompletableSource> FlowableFlatMapCompletableCompletable.FlatMapCompletableMainSubscriber.mapper
(package private) final Function
<? super T, ? extends CompletableSource> FlowableFlatMapCompletableCompletable.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableFlatMapMaybe.FlatMapMaybeSubscriber.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableFlatMapMaybe.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableFlatMapMaybePublisher.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> FlowableFlatMapSingle.FlatMapSingleSubscriber.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> FlowableFlatMapSingle.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> FlowableFlatMapSinglePublisher.mapper
FlowableFlattenIterable.FlattenIterableSubscriber.mapper
FlowableFlattenIterable.mapper
FlowableInternalHelper.FlatMapIntoIterable.mapper
FlowableInternalHelper.FlatMapWithCombinerOuter.mapper
FlowableMap.MapConditionalSubscriber.mapper
FlowableMap.mapper
FlowableMap.MapSubscriber.mapper
FlowableMapPublisher.mapper
FlowableScalarXMap.ScalarXMapFlowable.mapper
FlowableSwitchMap.mapper
FlowableSwitchMap.SwitchMapSubscriber.mapper
(package private) final Function
<? super Throwable, ? extends org.reactivestreams.Publisher<? extends T>> FlowableOnErrorNext.nextSupplier
(package private) final Function
<? super Throwable, ? extends org.reactivestreams.Publisher<? extends T>> FlowableOnErrorNext.OnErrorNextSubscriber.nextSupplier
FlowableMapNotification.MapNotificationSubscriber.onErrorMapper
FlowableMapNotification.onErrorMapper
FlowableMapNotification.MapNotificationSubscriber.onNextMapper
FlowableMapNotification.onNextMapper
FlowableGroupJoin.GroupJoinSubscription.rightEnd
FlowableGroupJoin.rightEnd
FlowableJoin.JoinSubscription.rightEnd
FlowableJoin.rightEnd
(package private) final Function
<? super T, ? extends Notification<R>> FlowableDematerialize.DematerializeSubscriber.selector
(package private) final Function
<? super T, ? extends Notification<R>> FlowableDematerialize.selector
(package private) final Function
<? super Flowable<T>, ? extends org.reactivestreams.Publisher<? extends R>> FlowablePublishMulticast.selector
FlowableReplay.MulticastFlowable.selector
FlowableUsing.sourceSupplier
FlowableGroupBy.GroupBySubscriber.valueSelector
FlowableGroupBy.valueSelector
FlowableOnErrorReturn.OnErrorReturnSubscriber.valueSupplier
FlowableOnErrorReturn.valueSupplier
FlowableZip.ZipCoordinator.zipper
FlowableZip.zipper
Methods in io.reactivex.rxjava3.internal.operators.flowable that return FunctionModifier and TypeMethodDescriptionstatic <T,
U> Function <T, org.reactivestreams.Publisher<U>> FlowableInternalHelper.flatMapIntoIterable
(Function<? super T, ? extends Iterable<? extends U>> mapper) static <T,
U, R> Function <T, org.reactivestreams.Publisher<R>> FlowableInternalHelper.flatMapWithCombiner
(Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> combiner) static <T,
U> Function <T, org.reactivestreams.Publisher<T>> FlowableInternalHelper.itemDelay
(Function<? super T, ? extends org.reactivestreams.Publisher<U>> itemDelay) Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FunctionModifier and TypeMethodDescriptionstatic <T,
U> Function <T, org.reactivestreams.Publisher<U>> FlowableInternalHelper.flatMapIntoIterable
(Function<? super T, ? extends Iterable<? extends U>> mapper) static <T,
U, R> Function <T, org.reactivestreams.Publisher<R>> FlowableInternalHelper.flatMapWithCombiner
(Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> combiner) static <T,
U> Function <T, org.reactivestreams.Publisher<T>> FlowableInternalHelper.itemDelay
(Function<? super T, ? extends org.reactivestreams.Publisher<U>> itemDelay) static <U,
R> Flowable <R> FlowableReplay.multicastSelector
(Supplier<? extends ConnectableFlowable<U>> connectableFactory, Function<? super Flowable<U>, ? extends org.reactivestreams.Publisher<R>> selector) Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.static <T,
U> Flowable <U> FlowableScalarXMap.scalarXMap
(T value, Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper) Maps a scalar value into a Publisher and emits its values.static <T,
R> org.reactivestreams.Subscriber <T> FlowableConcatMap.subscribe
(org.reactivestreams.Subscriber<? super R> s, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode) static <T,
U> FlowableSubscriber <T> FlowableFlatMap.subscribe
(org.reactivestreams.Subscriber<? super U> s, Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize) static <T,
R> org.reactivestreams.Subscriber <T> FlowableFlattenIterable.subscribe
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends Iterable<? extends R>> mapper, int prefetch) Create aSubscriber
with the given parameters.static <T,
R> boolean FlowableScalarXMap.tryScalarXMapSubscribe
(org.reactivestreams.Publisher<T> source, org.reactivestreams.Subscriber<? super R> subscriber, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper) Tries to subscribe to a possibly Supplier source's mapped Publisher.Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type FunctionModifierConstructorDescription(package private)
BaseConcatMapSubscriber
(Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch) (package private)
BaseConcatMapSubscriber
(Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, Scheduler.Worker worker) (package private)
BufferBoundarySubscriber
(org.reactivestreams.Subscriber<? super C> actual, org.reactivestreams.Publisher<? extends Open> bufferOpen, Function<? super Open, ? extends org.reactivestreams.Publisher<? extends Close>> bufferClose, Supplier<C> bufferSupplier) (package private)
CombineLatestCoordinator
(org.reactivestreams.Subscriber<? super R> actual, Function<? super Object[], ? extends R> combiner, int n, int bufferSize, boolean delayErrors) (package private)
ConcatMapDelayed
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, boolean veryEnd) (package private)
ConcatMapDelayed
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, boolean veryEnd, Scheduler.Worker worker) (package private)
ConcatMapEagerDelayErrorSubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int maxConcurrency, int prefetch, ErrorMode errorMode) (package private)
ConcatMapImmediate
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch) (package private)
ConcatMapImmediate
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, Scheduler.Worker worker) (package private)
DebounceSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Function<? super T, ? extends org.reactivestreams.Publisher<U>> debounceSelector) (package private)
DematerializeSubscriber
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends Notification<R>> selector) (package private)
DistinctSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Function<? super T, K> keySelector, Collection<? super K> collection) (package private)
DistinctUntilChangedConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Function<? super T, K> keySelector, BiPredicate<? super K, ? super K> comparer) (package private)
DistinctUntilChangedSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Function<? super T, K> keySelector, BiPredicate<? super K, ? super K> comparer) (package private)
FlatMapCompletableMainSubscriber
(org.reactivestreams.Subscriber<? super T> subscriber, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors, int maxConcurrency) (package private)
FlatMapCompletableMainSubscriber
(CompletableObserver observer, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors, int maxConcurrency) (package private)
FlatMapIntoIterable
(Function<? super T, ? extends Iterable<? extends U>> mapper) (package private)
FlatMapMaybeSubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors, int maxConcurrency) (package private)
FlatMapSingleSubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayErrors, int maxConcurrency) (package private)
FlatMapWithCombinerOuter
(BiFunction<? super T, ? super U, ? extends R> combiner, Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper) (package private)
FlattenIterableSubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends Iterable<? extends R>> mapper, int prefetch) FlowableBufferBoundary
(Flowable<T> source, org.reactivestreams.Publisher<? extends Open> bufferOpen, Function<? super Open, ? extends org.reactivestreams.Publisher<? extends Close>> bufferClose, Supplier<U> bufferSupplier) FlowableCombineLatest
(@NonNull Iterable<? extends org.reactivestreams.Publisher<? extends T>> iterable, @NonNull Function<? super Object[], ? extends R> combiner, int bufferSize, boolean delayErrors) FlowableCombineLatest
(@NonNull org.reactivestreams.Publisher<? extends T>[] array, @NonNull Function<? super Object[], ? extends R> combiner, int bufferSize, boolean delayErrors) FlowableConcatMap
(Flowable<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode) FlowableConcatMapEager
(Flowable<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int maxConcurrency, int prefetch, ErrorMode errorMode) FlowableConcatMapEagerPublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int maxConcurrency, int prefetch, ErrorMode errorMode) FlowableConcatMapScheduler
(Flowable<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode, Scheduler scheduler) FlowableDebounce
(Flowable<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<U>> debounceSelector) FlowableDematerialize
(Flowable<T> source, Function<? super T, ? extends Notification<R>> selector) FlowableDistinct
(Flowable<T> source, Function<? super T, K> keySelector, Supplier<? extends Collection<? super K>> collectionSupplier) FlowableDistinctUntilChanged
(Flowable<T> source, Function<? super T, K> keySelector, BiPredicate<? super K, ? super K> comparer) FlowableFlatMap
(Flowable<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize) FlowableFlatMapCompletable
(Flowable<T> source, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors, int maxConcurrency) FlowableFlatMapCompletableCompletable
(Flowable<T> source, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors, int maxConcurrency) FlowableFlatMapMaybe
(Flowable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayError, int maxConcurrency) FlowableFlatMapMaybePublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayError, int maxConcurrency) FlowableFlatMapSingle
(Flowable<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayError, int maxConcurrency) FlowableFlatMapSinglePublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayError, int maxConcurrency) FlowableFlattenIterable
(Flowable<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper, int prefetch) FlowableGroupBy
(Flowable<T> source, Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, int bufferSize, boolean delayError, Function<? super Consumer<Object>, ? extends Map<K, Object>> mapFactory) FlowableGroupJoin
(Flowable<TLeft> source, org.reactivestreams.Publisher<? extends TRight> other, Function<? super TLeft, ? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd, Function<? super TRight, ? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super Flowable<TRight>, ? extends R> resultSelector) FlowableJoin
(Flowable<TLeft> source, org.reactivestreams.Publisher<? extends TRight> other, Function<? super TLeft, ? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd, Function<? super TRight, ? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector) FlowableMapNotification
(Flowable<T> source, Function<? super T, ? extends R> onNextMapper, Function<? super Throwable, ? extends R> onErrorMapper, Supplier<? extends R> onCompleteSupplier) FlowableMapPublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends U> mapper) FlowableOnErrorNext
(Flowable<T> source, Function<? super Throwable, ? extends org.reactivestreams.Publisher<? extends T>> nextSupplier) FlowablePublishMulticast
(Flowable<T> source, Function<? super Flowable<T>, ? extends org.reactivestreams.Publisher<? extends R>> selector, int prefetch, boolean delayError) FlowableRepeatWhen
(Flowable<T> source, Function<? super Flowable<Object>, ? extends org.reactivestreams.Publisher<?>> handler) FlowableRetryWhen
(Flowable<T> source, Function<? super Flowable<Throwable>, ? extends org.reactivestreams.Publisher<?>> handler) FlowableSwitchMap
(Flowable<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int bufferSize, boolean delayErrors) FlowableTimeout
(Flowable<T> source, org.reactivestreams.Publisher<U> firstTimeoutIndicator, Function<? super T, ? extends org.reactivestreams.Publisher<V>> itemTimeoutIndicator, org.reactivestreams.Publisher<? extends T> other) FlowableUsing
(Supplier<? extends D> resourceSupplier, Function<? super D, ? extends org.reactivestreams.Publisher<? extends T>> sourceSupplier, Consumer<? super D> disposer, boolean eager) FlowableWindowBoundarySelector
(Flowable<T> source, org.reactivestreams.Publisher<B> open, Function<? super B, ? extends org.reactivestreams.Publisher<V>> closingIndicator, int bufferSize) FlowableWithLatestFromMany
(@NonNull Flowable<T> source, @NonNull Iterable<? extends org.reactivestreams.Publisher<?>> otherIterable, @NonNull Function<? super Object[], R> combiner) FlowableWithLatestFromMany
(@NonNull Flowable<T> source, @NonNull org.reactivestreams.Publisher<?>[] otherArray, Function<? super Object[], R> combiner) FlowableZip
(org.reactivestreams.Publisher<? extends T>[] sources, Iterable<? extends org.reactivestreams.Publisher<? extends T>> sourcesIterable, Function<? super Object[], ? extends R> zipper, int bufferSize, boolean delayError) GroupBySubscriber
(org.reactivestreams.Subscriber<? super GroupedFlowable<K, V>> actual, Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, int bufferSize, boolean delayError, Map<Object, FlowableGroupBy.GroupedUnicast<K, V>> groups, Queue<FlowableGroupBy.GroupedUnicast<K, V>> evictedGroups) (package private)
GroupJoinSubscription
(org.reactivestreams.Subscriber<? super R> actual, Function<? super TLeft, ? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd, Function<? super TRight, ? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super Flowable<TRight>, ? extends R> resultSelector) (package private)
ItemDelayFunction
(Function<? super T, ? extends org.reactivestreams.Publisher<U>> itemDelay) (package private)
JoinSubscription
(org.reactivestreams.Subscriber<? super R> actual, Function<? super TLeft, ? extends org.reactivestreams.Publisher<TLeftEnd>> leftEnd, Function<? super TRight, ? extends org.reactivestreams.Publisher<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector) (package private)
MapConditionalSubscriber
(ConditionalSubscriber<? super U> actual, Function<? super T, ? extends U> function) (package private)
MapNotificationSubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends R> onNextMapper, Function<? super Throwable, ? extends R> onErrorMapper, Supplier<? extends R> onCompleteSupplier) (package private)
MapSubscriber
(org.reactivestreams.Subscriber<? super U> actual, Function<? super T, ? extends U> mapper) (package private)
MergeSubscriber
(org.reactivestreams.Subscriber<? super U> actual, Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize) (package private)
MulticastFlowable
(Supplier<? extends ConnectableFlowable<U>> connectableFactory, Function<? super Flowable<U>, ? extends org.reactivestreams.Publisher<R>> selector) (package private)
OnErrorNextSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Function<? super Throwable, ? extends org.reactivestreams.Publisher<? extends T>> nextSupplier) (package private)
OnErrorReturnSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Function<? super Throwable, ? extends T> valueSupplier) (package private)
ScalarXMapFlowable
(T value, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper) (package private)
SwitchMapSubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int bufferSize, boolean delayErrors) (package private)
TimeoutFallbackSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Function<? super T, ? extends org.reactivestreams.Publisher<?>> itemTimeoutIndicator, org.reactivestreams.Publisher<? extends T> fallback) (package private)
TimeoutSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Function<? super T, ? extends org.reactivestreams.Publisher<?>> itemTimeoutIndicator) (package private)
WindowBoundaryMainSubscriber
(org.reactivestreams.Subscriber<? super Flowable<T>> actual, org.reactivestreams.Publisher<B> open, Function<? super B, ? extends org.reactivestreams.Publisher<V>> closingIndicator, int bufferSize) (package private)
WithLatestFromSubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super Object[], R> combiner, int n) (package private)
ZipCoordinator
(org.reactivestreams.Subscriber<? super R> actual, Function<? super Object[], ? extends R> zipper, int n, int prefetch, boolean delayErrors) -
Uses of Function in io.reactivex.rxjava3.internal.operators.maybe
Classes in io.reactivex.rxjava3.internal.operators.maybe that implement FunctionModifier and TypeClassDescriptionenum
Helper function to merge/concat values of each MaybeSource provided by a Publisher.(package private) final class
(package private) final class
Fields in io.reactivex.rxjava3.internal.operators.maybe declared as FunctionModifier and TypeFieldDescriptionMaybeOnErrorReturn.itemSupplier
MaybeOnErrorReturn.OnErrorReturnMaybeObserver.itemSupplier
(package private) final Function
<? super T, ? extends MaybeSource<? extends U>> MaybeFlatMapBiSelector.FlatMapBiMainObserver.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends U>> MaybeFlatMapBiSelector.mapper
(package private) final Function
<? super T, ? extends CompletableSource> MaybeFlatMapCompletable.FlatMapCompletableObserver.mapper
(package private) final Function
<? super T, ? extends CompletableSource> MaybeFlatMapCompletable.mapper
MaybeFlatMapIterableFlowable.FlatMapIterableObserver.mapper
MaybeFlatMapIterableFlowable.mapper
MaybeFlatMapIterableObservable.FlatMapIterableObserver.mapper
MaybeFlatMapIterableObservable.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> MaybeFlatMapSingle.FlatMapMaybeObserver.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> MaybeFlatMapSingle.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> MaybeFlatten.FlatMapMaybeObserver.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> MaybeFlatten.mapper
MaybeMap.MapMaybeObserver.mapper
MaybeMap.mapper
(package private) final Function
<? super Throwable, ? extends MaybeSource<? extends R>> MaybeFlatMapNotification.FlatMapMaybeObserver.onErrorMapper
(package private) final Function
<? super Throwable, ? extends MaybeSource<? extends R>> MaybeFlatMapNotification.onErrorMapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> MaybeFlatMapNotification.FlatMapMaybeObserver.onSuccessMapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> MaybeFlatMapNotification.onSuccessMapper
(package private) final Function
<? super Throwable, ? extends MaybeSource<? extends T>> MaybeOnErrorNext.OnErrorNextMaybeObserver.resumeFunction
(package private) final Function
<? super Throwable, ? extends MaybeSource<? extends T>> MaybeOnErrorNext.resumeFunction
(package private) final Function
<? super T, Notification<R>> MaybeDematerialize.DematerializeObserver.selector
(package private) final Function
<? super T, Notification<R>> MaybeDematerialize.selector
(package private) final Function
<? super D, ? extends MaybeSource<? extends T>> MaybeUsing.sourceSupplier
MaybeZipArray.ZipCoordinator.zipper
MaybeZipArray.zipper
MaybeZipIterable.zipper
Methods in io.reactivex.rxjava3.internal.operators.maybe that return FunctionModifier and TypeMethodDescriptionstatic <T> Function
<MaybeSource<T>, org.reactivestreams.Publisher<T>> MaybeToPublisher.instance()
Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type FunctionModifierConstructorDescription(package private)
DematerializeObserver
(MaybeObserver<? super R> downstream, Function<? super T, Notification<R>> selector) (package private)
FlatMapBiMainObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector) (package private)
FlatMapCompletableObserver
(CompletableObserver actual, Function<? super T, ? extends CompletableSource> mapper) (package private)
FlatMapIterableObserver
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends Iterable<? extends R>> mapper) (package private)
FlatMapIterableObserver
(Observer<? super R> actual, Function<? super T, ? extends Iterable<? extends R>> mapper) (package private)
FlatMapMaybeObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper, Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper, Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier) (package private)
FlatMapMaybeObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends SingleSource<? extends R>> mapper) (package private)
FlatMapMaybeObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> mapper) (package private)
MapMaybeObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends R> mapper) MaybeDematerialize
(Maybe<T> source, Function<? super T, Notification<R>> selector) MaybeFlatMapBiSelector
(MaybeSource<T> source, Function<? super T, ? extends MaybeSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector) MaybeFlatMapCompletable
(MaybeSource<T> source, Function<? super T, ? extends CompletableSource> mapper) MaybeFlatMapIterableFlowable
(MaybeSource<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper) MaybeFlatMapIterableObservable
(MaybeSource<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper) MaybeFlatMapNotification
(MaybeSource<T> source, Function<? super T, ? extends MaybeSource<? extends R>> onSuccessMapper, Function<? super Throwable, ? extends MaybeSource<? extends R>> onErrorMapper, Supplier<? extends MaybeSource<? extends R>> onCompleteSupplier) MaybeFlatMapSingle
(MaybeSource<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper) MaybeFlatten
(MaybeSource<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper) MaybeOnErrorNext
(MaybeSource<T> source, Function<? super Throwable, ? extends MaybeSource<? extends T>> resumeFunction) MaybeOnErrorReturn
(MaybeSource<T> source, Function<? super Throwable, ? extends T> itemSupplier) MaybeUsing
(Supplier<? extends D> resourceSupplier, Function<? super D, ? extends MaybeSource<? extends T>> sourceSupplier, Consumer<? super D> resourceDisposer, boolean eager) MaybeZipArray
(MaybeSource<? extends T>[] sources, Function<? super Object[], ? extends R> zipper) MaybeZipIterable
(Iterable<? extends MaybeSource<? extends T>> sources, Function<? super Object[], ? extends R> zipper) (package private)
OnErrorNextMaybeObserver
(MaybeObserver<? super T> actual, Function<? super Throwable, ? extends MaybeSource<? extends T>> resumeFunction) (package private)
OnErrorReturnMaybeObserver
(MaybeObserver<? super T> actual, Function<? super Throwable, ? extends T> valueSupplier) (package private)
ZipCoordinator
(MaybeObserver<? super R> observer, int n, Function<? super Object[], ? extends R> zipper) -
Uses of Function in io.reactivex.rxjava3.internal.operators.mixed
Fields in io.reactivex.rxjava3.internal.operators.mixed declared as FunctionModifier and TypeFieldDescription(package private) final Function
<? super T, ? extends CompletableSource> FlowableConcatMapCompletable.ConcatMapCompletableObserver.mapper
(package private) final Function
<? super T, ? extends CompletableSource> FlowableConcatMapCompletable.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableConcatMapMaybe.ConcatMapMaybeSubscriber.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableConcatMapMaybe.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableConcatMapMaybePublisher.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> FlowableConcatMapSingle.ConcatMapSingleSubscriber.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> FlowableConcatMapSingle.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> FlowableConcatMapSinglePublisher.mapper
(package private) final Function
<? super T, ? extends CompletableSource> FlowableSwitchMapCompletable.mapper
(package private) final Function
<? super T, ? extends CompletableSource> FlowableSwitchMapCompletable.SwitchMapCompletableObserver.mapper
(package private) final Function
<? super T, ? extends CompletableSource> FlowableSwitchMapCompletablePublisher.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableSwitchMapMaybe.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableSwitchMapMaybe.SwitchMapMaybeSubscriber.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> FlowableSwitchMapMaybePublisher.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> FlowableSwitchMapSingle.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> FlowableSwitchMapSingle.SwitchMapSingleSubscriber.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> FlowableSwitchMapSinglePublisher.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> MaybeFlatMapObservable.FlatMapObserver.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> MaybeFlatMapObservable.mapper
MaybeFlatMapPublisher.FlatMapPublisherSubscriber.mapper
MaybeFlatMapPublisher.mapper
(package private) final Function
<? super T, ? extends CompletableSource> ObservableConcatMapCompletable.ConcatMapCompletableObserver.mapper
(package private) final Function
<? super T, ? extends CompletableSource> ObservableConcatMapCompletable.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableConcatMapMaybe.ConcatMapMaybeMainObserver.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableConcatMapMaybe.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> ObservableConcatMapSingle.ConcatMapSingleMainObserver.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> ObservableConcatMapSingle.mapper
(package private) final Function
<? super T, ? extends CompletableSource> ObservableSwitchMapCompletable.mapper
(package private) final Function
<? super T, ? extends CompletableSource> ObservableSwitchMapCompletable.SwitchMapCompletableObserver.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableSwitchMapMaybe.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableSwitchMapMaybe.SwitchMapMaybeMainObserver.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> ObservableSwitchMapSingle.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> ObservableSwitchMapSingle.SwitchMapSingleMainObserver.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> SingleFlatMapObservable.FlatMapObserver.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> SingleFlatMapObservable.mapper
Methods in io.reactivex.rxjava3.internal.operators.mixed with parameters of type FunctionModifier and TypeMethodDescription(package private) static <T> boolean
ScalarXMapZHelper.tryAsCompletable
(Object source, Function<? super T, ? extends CompletableSource> mapper, CompletableObserver observer) Try subscribing to aCompletableSource
mapped from a scalar source (which implementsSupplier
).(package private) static <T,
R> boolean ScalarXMapZHelper.tryAsMaybe
(Object source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, Observer<? super R> observer) Try subscribing to aMaybeSource
mapped from a scalar source (which implementsSupplier
).(package private) static <T,
R> boolean ScalarXMapZHelper.tryAsSingle
(Object source, Function<? super T, ? extends SingleSource<? extends R>> mapper, Observer<? super R> observer) Try subscribing to aSingleSource
mapped from a scalar source (which implementsSupplier
).Constructors in io.reactivex.rxjava3.internal.operators.mixed with parameters of type FunctionModifierConstructorDescription(package private)
ConcatMapCompletableObserver
(CompletableObserver downstream, Function<? super T, ? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch) (package private)
ConcatMapCompletableObserver
(CompletableObserver downstream, Function<? super T, ? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch) (package private)
ConcatMapMaybeMainObserver
(Observer<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, int prefetch, ErrorMode errorMode) (package private)
ConcatMapMaybeSubscriber
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, int prefetch, ErrorMode errorMode) (package private)
ConcatMapSingleMainObserver
(Observer<? super R> downstream, Function<? super T, ? extends SingleSource<? extends R>> mapper, int prefetch, ErrorMode errorMode) (package private)
ConcatMapSingleSubscriber
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends SingleSource<? extends R>> mapper, int prefetch, ErrorMode errorMode) (package private)
FlatMapObserver
(Observer<? super R> downstream, Function<? super T, ? extends ObservableSource<? extends R>> mapper) (package private)
FlatMapObserver
(Observer<? super R> downstream, Function<? super T, ? extends ObservableSource<? extends R>> mapper) (package private)
FlatMapPublisherSubscriber
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper) FlowableConcatMapCompletable
(Flowable<T> source, Function<? super T, ? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch) FlowableConcatMapMaybe
(Flowable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch) FlowableConcatMapMaybePublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch) FlowableConcatMapSingle
(Flowable<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper, ErrorMode errorMode, int prefetch) FlowableConcatMapSinglePublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper, ErrorMode errorMode, int prefetch) FlowableSwitchMapCompletable
(Flowable<T> source, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors) FlowableSwitchMapCompletablePublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors) FlowableSwitchMapMaybe
(Flowable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) FlowableSwitchMapMaybePublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) FlowableSwitchMapSingle
(Flowable<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayErrors) FlowableSwitchMapSinglePublisher
(org.reactivestreams.Publisher<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayErrors) MaybeFlatMapObservable
(MaybeSource<T> source, Function<? super T, ? extends ObservableSource<? extends R>> mapper) MaybeFlatMapPublisher
(MaybeSource<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper) ObservableConcatMapCompletable
(Observable<T> source, Function<? super T, ? extends CompletableSource> mapper, ErrorMode errorMode, int prefetch) ObservableConcatMapMaybe
(Observable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, ErrorMode errorMode, int prefetch) ObservableConcatMapSingle
(ObservableSource<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper, ErrorMode errorMode, int prefetch) ObservableSwitchMapCompletable
(Observable<T> source, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors) ObservableSwitchMapMaybe
(Observable<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) ObservableSwitchMapSingle
(Observable<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayErrors) SingleFlatMapObservable
(SingleSource<T> source, Function<? super T, ? extends ObservableSource<? extends R>> mapper) (package private)
SwitchMapCompletableObserver
(CompletableObserver downstream, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors) (package private)
SwitchMapCompletableObserver
(CompletableObserver downstream, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors) (package private)
SwitchMapMaybeMainObserver
(Observer<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) (package private)
SwitchMapMaybeSubscriber
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) (package private)
SwitchMapSingleMainObserver
(Observer<? super R> downstream, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayErrors) (package private)
SwitchMapSingleSubscriber
(org.reactivestreams.Subscriber<? super R> downstream, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayErrors) -
Uses of Function in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement FunctionModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static enum
(package private) final class
Fields in io.reactivex.rxjava3.internal.operators.observable declared as FunctionModifier and TypeFieldDescription(package private) final Function
<? super Open, ? extends ObservableSource<? extends Close>> ObservableBufferBoundary.BufferBoundaryObserver.bufferClose
(package private) final Function
<? super Open, ? extends ObservableSource<? extends Close>> ObservableBufferBoundary.bufferClose
(package private) final Function
<? super B, ? extends ObservableSource<V>> ObservableWindowBoundarySelector.closingIndicator
(package private) final Function
<? super B, ? extends ObservableSource<V>> ObservableWindowBoundarySelector.WindowBoundaryMainObserver.closingIndicator
ObservableCombineLatest.combiner
ObservableCombineLatest.LatestCoordinator.combiner
ObservableWithLatestFromMany.combiner
ObservableWithLatestFromMany.WithLatestFromObserver.combiner
(package private) final Function
<? super T, ? extends ObservableSource<U>> ObservableDebounce.DebounceObserver.debounceSelector
(package private) final Function
<? super T, ? extends ObservableSource<U>> ObservableDebounce.debounceSelector
ObservableMap.function
(package private) final Function
<? super Observable<Object>, ? extends ObservableSource<?>> ObservableRepeatWhen.handler
(package private) final Function
<? super Observable<Throwable>, ? extends ObservableSource<?>> ObservableRetryWhen.handler
(package private) final Function
<? super T, ? extends ObservableSource<U>> ObservableInternalHelper.ItemDelayFunction.itemDelay
(package private) final Function
<? super T, ? extends ObservableSource<V>> ObservableTimeout.itemTimeoutIndicator
(package private) final Function
<? super T, ? extends ObservableSource<?>> ObservableTimeout.TimeoutFallbackObserver.itemTimeoutIndicator
(package private) final Function
<? super T, ? extends ObservableSource<?>> ObservableTimeout.TimeoutObserver.itemTimeoutIndicator
ObservableDistinct.DistinctObserver.keySelector
ObservableDistinct.keySelector
ObservableDistinctUntilChanged.DistinctUntilChangedObserver.keySelector
ObservableDistinctUntilChanged.keySelector
ObservableGroupBy.GroupByObserver.keySelector
ObservableGroupBy.keySelector
(package private) final Function
<? super TLeft, ? extends ObservableSource<TLeftEnd>> ObservableGroupJoin.GroupJoinDisposable.leftEnd
(package private) final Function
<? super TLeft, ? extends ObservableSource<TLeftEnd>> ObservableGroupJoin.leftEnd
(package private) final Function
<? super TLeft, ? extends ObservableSource<TLeftEnd>> ObservableJoin.JoinDisposable.leftEnd
(package private) final Function
<? super TLeft, ? extends ObservableSource<TLeftEnd>> ObservableJoin.leftEnd
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> ObservableConcatMap.ConcatMapDelayErrorObserver.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends U>> ObservableConcatMap.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends U>> ObservableConcatMap.SourceObserver.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> ObservableConcatMapEager.ConcatMapEagerMainObserver.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> ObservableConcatMapEager.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> ObservableConcatMapScheduler.ConcatMapDelayErrorObserver.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends U>> ObservableConcatMapScheduler.ConcatMapObserver.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends U>> ObservableConcatMapScheduler.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends U>> ObservableFlatMap.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends U>> ObservableFlatMap.MergeObserver.mapper
(package private) final Function
<? super T, ? extends CompletableSource> ObservableFlatMapCompletable.FlatMapCompletableMainObserver.mapper
(package private) final Function
<? super T, ? extends CompletableSource> ObservableFlatMapCompletable.mapper
(package private) final Function
<? super T, ? extends CompletableSource> ObservableFlatMapCompletableCompletable.FlatMapCompletableMainObserver.mapper
(package private) final Function
<? super T, ? extends CompletableSource> ObservableFlatMapCompletableCompletable.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableFlatMapMaybe.FlatMapMaybeObserver.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> ObservableFlatMapMaybe.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> ObservableFlatMapSingle.FlatMapSingleObserver.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> ObservableFlatMapSingle.mapper
ObservableFlattenIterable.FlattenIterableObserver.mapper
ObservableFlattenIterable.mapper
ObservableInternalHelper.FlatMapIntoIterable.mapper
private final Function
<? super T, ? extends ObservableSource<? extends U>> ObservableInternalHelper.FlatMapWithCombinerOuter.mapper
ObservableMap.MapObserver.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> ObservableScalarXMap.ScalarXMapObservable.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> ObservableSwitchMap.mapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> ObservableSwitchMap.SwitchMapObserver.mapper
(package private) final Function
<? super Throwable, ? extends ObservableSource<? extends T>> ObservableOnErrorNext.nextSupplier
(package private) final Function
<? super Throwable, ? extends ObservableSource<? extends T>> ObservableOnErrorNext.OnErrorNextObserver.nextSupplier
(package private) final Function
<? super Throwable, ? extends ObservableSource<? extends R>> ObservableMapNotification.MapNotificationObserver.onErrorMapper
(package private) final Function
<? super Throwable, ? extends ObservableSource<? extends R>> ObservableMapNotification.onErrorMapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> ObservableMapNotification.MapNotificationObserver.onNextMapper
(package private) final Function
<? super T, ? extends ObservableSource<? extends R>> ObservableMapNotification.onNextMapper
(package private) final Function
<? super TRight, ? extends ObservableSource<TRightEnd>> ObservableGroupJoin.GroupJoinDisposable.rightEnd
(package private) final Function
<? super TRight, ? extends ObservableSource<TRightEnd>> ObservableGroupJoin.rightEnd
(package private) final Function
<? super TRight, ? extends ObservableSource<TRightEnd>> ObservableJoin.JoinDisposable.rightEnd
(package private) final Function
<? super TRight, ? extends ObservableSource<TRightEnd>> ObservableJoin.rightEnd
(package private) final Function
<? super T, ? extends Notification<R>> ObservableDematerialize.DematerializeObserver.selector
(package private) final Function
<? super T, ? extends Notification<R>> ObservableDematerialize.selector
(package private) final Function
<? super Observable<T>, ? extends ObservableSource<R>> ObservablePublishSelector.selector
private final Function
<? super Observable<U>, ? extends ObservableSource<R>> ObservableReplay.MulticastReplay.selector
(package private) final Function
<? super D, ? extends ObservableSource<? extends T>> ObservableUsing.sourceSupplier
ObservableGroupBy.GroupByObserver.valueSelector
ObservableGroupBy.valueSelector
ObservableOnErrorReturn.OnErrorReturnObserver.valueSupplier
ObservableOnErrorReturn.valueSupplier
ObservableZip.ZipCoordinator.zipper
ObservableZip.zipper
Methods in io.reactivex.rxjava3.internal.operators.observable that return FunctionModifier and TypeMethodDescriptionstatic <T,
U> Function <T, ObservableSource<U>> ObservableInternalHelper.flatMapIntoIterable
(Function<? super T, ? extends Iterable<? extends U>> mapper) static <T,
U, R> Function <T, ObservableSource<R>> ObservableInternalHelper.flatMapWithCombiner
(Function<? super T, ? extends ObservableSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> combiner) static <T,
U> Function <T, ObservableSource<T>> ObservableInternalHelper.itemDelay
(Function<? super T, ? extends ObservableSource<U>> itemDelay) Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type FunctionModifier and TypeMethodDescriptionstatic <T,
U> Function <T, ObservableSource<U>> ObservableInternalHelper.flatMapIntoIterable
(Function<? super T, ? extends Iterable<? extends U>> mapper) static <T,
U, R> Function <T, ObservableSource<R>> ObservableInternalHelper.flatMapWithCombiner
(Function<? super T, ? extends ObservableSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> combiner) static <T,
U> Function <T, ObservableSource<T>> ObservableInternalHelper.itemDelay
(Function<? super T, ? extends ObservableSource<U>> itemDelay) static <U,
R> Observable <R> ObservableReplay.multicastSelector
(Supplier<? extends ConnectableObservable<U>> connectableFactory, Function<? super Observable<U>, ? extends ObservableSource<R>> selector) Given a connectable observable factory, it multicasts over the generated ConnectableObservable via a selector function.static <T,
U> Observable <U> ObservableScalarXMap.scalarXMap
(T value, Function<? super T, ? extends ObservableSource<? extends U>> mapper) Maps a scalar value into an Observable and emits its values.static <T,
R> boolean ObservableScalarXMap.tryScalarXMapSubscribe
(ObservableSource<T> source, Observer<? super R> observer, Function<? super T, ? extends ObservableSource<? extends R>> mapper) Tries to subscribe to a possibly Supplier source's mapped ObservableSource.Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type FunctionModifierConstructorDescription(package private)
BufferBoundaryObserver
(Observer<? super C> actual, ObservableSource<? extends Open> bufferOpen, Function<? super Open, ? extends ObservableSource<? extends Close>> bufferClose, Supplier<C> bufferSupplier) (package private)
ConcatMapDelayErrorObserver
(Observer<? super R> actual, Function<? super T, ? extends ObservableSource<? extends R>> mapper, int bufferSize, boolean tillTheEnd) (package private)
ConcatMapDelayErrorObserver
(Observer<? super R> actual, Function<? super T, ? extends ObservableSource<? extends R>> mapper, int bufferSize, boolean tillTheEnd, Scheduler.Worker worker) (package private)
ConcatMapEagerMainObserver
(Observer<? super R> actual, Function<? super T, ? extends ObservableSource<? extends R>> mapper, int maxConcurrency, int prefetch, ErrorMode errorMode) (package private)
ConcatMapObserver
(Observer<? super U> actual, Function<? super T, ? extends ObservableSource<? extends U>> mapper, int bufferSize, Scheduler.Worker worker) (package private)
DebounceObserver
(Observer<? super T> actual, Function<? super T, ? extends ObservableSource<U>> debounceSelector) (package private)
DematerializeObserver
(Observer<? super R> downstream, Function<? super T, ? extends Notification<R>> selector) (package private)
DistinctObserver
(Observer<? super T> actual, Function<? super T, K> keySelector, Collection<? super K> collection) (package private)
DistinctUntilChangedObserver
(Observer<? super T> actual, Function<? super T, K> keySelector, BiPredicate<? super K, ? super K> comparer) (package private)
FlatMapCompletableMainObserver
(Observer<? super T> observer, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors) (package private)
FlatMapCompletableMainObserver
(CompletableObserver observer, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors) (package private)
FlatMapIntoIterable
(Function<? super T, ? extends Iterable<? extends U>> mapper) (package private)
FlatMapMaybeObserver
(Observer<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayErrors) (package private)
FlatMapSingleObserver
(Observer<? super R> actual, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayErrors) (package private)
FlatMapWithCombinerOuter
(BiFunction<? super T, ? super U, ? extends R> combiner, Function<? super T, ? extends ObservableSource<? extends U>> mapper) (package private)
FlattenIterableObserver
(Observer<? super R> actual, Function<? super T, ? extends Iterable<? extends R>> mapper) GroupByObserver
(Observer<? super GroupedObservable<K, V>> actual, Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, int bufferSize, boolean delayError) (package private)
GroupJoinDisposable
(Observer<? super R> actual, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super Observable<TRight>, ? extends R> resultSelector) (package private)
ItemDelayFunction
(Function<? super T, ? extends ObservableSource<U>> itemDelay) (package private)
JoinDisposable
(Observer<? super R> actual, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector) (package private)
LatestCoordinator
(Observer<? super R> actual, Function<? super Object[], ? extends R> combiner, int count, int bufferSize, boolean delayError) (package private)
MapNotificationObserver
(Observer<? super ObservableSource<? extends R>> actual, Function<? super T, ? extends ObservableSource<? extends R>> onNextMapper, Function<? super Throwable, ? extends ObservableSource<? extends R>> onErrorMapper, Supplier<? extends ObservableSource<? extends R>> onCompleteSupplier) (package private)
(package private)
MergeObserver
(Observer<? super U> actual, Function<? super T, ? extends ObservableSource<? extends U>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize) (package private)
MulticastReplay
(Supplier<? extends ConnectableObservable<U>> connectableFactory, Function<? super Observable<U>, ? extends ObservableSource<R>> selector) ObservableBufferBoundary
(ObservableSource<T> source, ObservableSource<? extends Open> bufferOpen, Function<? super Open, ? extends ObservableSource<? extends Close>> bufferClose, Supplier<U> bufferSupplier) ObservableCombineLatest
(ObservableSource<? extends T>[] sources, Iterable<? extends ObservableSource<? extends T>> sourcesIterable, Function<? super Object[], ? extends R> combiner, int bufferSize, boolean delayError) ObservableConcatMap
(ObservableSource<T> source, Function<? super T, ? extends ObservableSource<? extends U>> mapper, int bufferSize, ErrorMode delayErrors) ObservableConcatMapEager
(ObservableSource<T> source, Function<? super T, ? extends ObservableSource<? extends R>> mapper, ErrorMode errorMode, int maxConcurrency, int prefetch) ObservableConcatMapScheduler
(ObservableSource<T> source, Function<? super T, ? extends ObservableSource<? extends U>> mapper, int bufferSize, ErrorMode delayErrors, Scheduler scheduler) ObservableDebounce
(ObservableSource<T> source, Function<? super T, ? extends ObservableSource<U>> debounceSelector) ObservableDematerialize
(ObservableSource<T> source, Function<? super T, ? extends Notification<R>> selector) ObservableDistinct
(ObservableSource<T> source, Function<? super T, K> keySelector, Supplier<? extends Collection<? super K>> collectionSupplier) ObservableDistinctUntilChanged
(ObservableSource<T> source, Function<? super T, K> keySelector, BiPredicate<? super K, ? super K> comparer) ObservableFlatMap
(ObservableSource<T> source, Function<? super T, ? extends ObservableSource<? extends U>> mapper, boolean delayErrors, int maxConcurrency, int bufferSize) ObservableFlatMapCompletable
(ObservableSource<T> source, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors) ObservableFlatMapCompletableCompletable
(ObservableSource<T> source, Function<? super T, ? extends CompletableSource> mapper, boolean delayErrors) ObservableFlatMapMaybe
(ObservableSource<T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper, boolean delayError) ObservableFlatMapSingle
(ObservableSource<T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper, boolean delayError) ObservableFlattenIterable
(ObservableSource<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper) ObservableGroupBy
(ObservableSource<T> source, Function<? super T, ? extends K> keySelector, Function<? super T, ? extends V> valueSelector, int bufferSize, boolean delayError) ObservableGroupJoin
(ObservableSource<TLeft> source, ObservableSource<? extends TRight> other, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super Observable<TRight>, ? extends R> resultSelector) ObservableJoin
(ObservableSource<TLeft> source, ObservableSource<? extends TRight> other, Function<? super TLeft, ? extends ObservableSource<TLeftEnd>> leftEnd, Function<? super TRight, ? extends ObservableSource<TRightEnd>> rightEnd, BiFunction<? super TLeft, ? super TRight, ? extends R> resultSelector) ObservableMap
(ObservableSource<T> source, Function<? super T, ? extends U> function) ObservableMapNotification
(ObservableSource<T> source, Function<? super T, ? extends ObservableSource<? extends R>> onNextMapper, Function<? super Throwable, ? extends ObservableSource<? extends R>> onErrorMapper, Supplier<? extends ObservableSource<? extends R>> onCompleteSupplier) ObservableOnErrorNext
(ObservableSource<T> source, Function<? super Throwable, ? extends ObservableSource<? extends T>> nextSupplier) ObservableOnErrorReturn
(ObservableSource<T> source, Function<? super Throwable, ? extends T> valueSupplier) ObservablePublishSelector
(ObservableSource<T> source, Function<? super Observable<T>, ? extends ObservableSource<R>> selector) ObservableRepeatWhen
(ObservableSource<T> source, Function<? super Observable<Object>, ? extends ObservableSource<?>> handler) ObservableRetryWhen
(ObservableSource<T> source, Function<? super Observable<Throwable>, ? extends ObservableSource<?>> handler) ObservableSwitchMap
(ObservableSource<T> source, Function<? super T, ? extends ObservableSource<? extends R>> mapper, int bufferSize, boolean delayErrors) ObservableTimeout
(Observable<T> source, ObservableSource<U> firstTimeoutIndicator, Function<? super T, ? extends ObservableSource<V>> itemTimeoutIndicator, ObservableSource<? extends T> other) ObservableUsing
(Supplier<? extends D> resourceSupplier, Function<? super D, ? extends ObservableSource<? extends T>> sourceSupplier, Consumer<? super D> disposer, boolean eager) ObservableWindowBoundarySelector
(ObservableSource<T> source, ObservableSource<B> open, Function<? super B, ? extends ObservableSource<V>> closingIndicator, int bufferSize) ObservableWithLatestFromMany
(@NonNull ObservableSource<T> source, @NonNull ObservableSource<?>[] otherArray, @NonNull Function<? super Object[], R> combiner) ObservableWithLatestFromMany
(@NonNull ObservableSource<T> source, @NonNull Iterable<? extends ObservableSource<?>> otherIterable, @NonNull Function<? super Object[], R> combiner) ObservableZip
(ObservableSource<? extends T>[] sources, Iterable<? extends ObservableSource<? extends T>> sourcesIterable, Function<? super Object[], ? extends R> zipper, int bufferSize, boolean delayError) (package private)
OnErrorNextObserver
(Observer<? super T> actual, Function<? super Throwable, ? extends ObservableSource<? extends T>> nextSupplier) (package private)
OnErrorReturnObserver
(Observer<? super T> actual, Function<? super Throwable, ? extends T> valueSupplier) (package private)
ScalarXMapObservable
(T value, Function<? super T, ? extends ObservableSource<? extends R>> mapper) (package private)
SourceObserver
(Observer<? super U> actual, Function<? super T, ? extends ObservableSource<? extends U>> mapper, int bufferSize) (package private)
SwitchMapObserver
(Observer<? super R> actual, Function<? super T, ? extends ObservableSource<? extends R>> mapper, int bufferSize, boolean delayErrors) (package private)
TimeoutFallbackObserver
(Observer<? super T> actual, Function<? super T, ? extends ObservableSource<?>> itemTimeoutIndicator, ObservableSource<? extends T> fallback) (package private)
TimeoutObserver
(Observer<? super T> actual, Function<? super T, ? extends ObservableSource<?>> itemTimeoutIndicator) (package private)
WindowBoundaryMainObserver
(Observer<? super Observable<T>> downstream, ObservableSource<B> open, Function<? super B, ? extends ObservableSource<V>> closingIndicator, int bufferSize) (package private)
(package private)
ZipCoordinator
(Observer<? super R> actual, Function<? super Object[], ? extends R> zipper, int count, boolean delayError) -
Uses of Function in io.reactivex.rxjava3.internal.operators.parallel
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as FunctionModifier and TypeFieldDescriptionParallelConcatMap.mapper
ParallelFlatMap.mapper
ParallelFlatMapIterable.mapper
ParallelMap.mapper
ParallelMap.ParallelMapConditionalSubscriber.mapper
ParallelMap.ParallelMapSubscriber.mapper
ParallelMapTry.mapper
ParallelMapTry.ParallelMapTryConditionalSubscriber.mapper
ParallelMapTry.ParallelMapTrySubscriber.mapper
Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type FunctionModifierConstructorDescriptionParallelConcatMap
(ParallelFlowable<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, int prefetch, ErrorMode errorMode) ParallelFlatMap
(ParallelFlowable<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper, boolean delayError, int maxConcurrency, int prefetch) ParallelFlatMapIterable
(ParallelFlowable<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper, int prefetch) ParallelMap
(ParallelFlowable<T> source, Function<? super T, ? extends R> mapper) (package private)
ParallelMapConditionalSubscriber
(ConditionalSubscriber<? super R> actual, Function<? super T, ? extends R> mapper) (package private)
ParallelMapSubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends R> mapper) ParallelMapTry
(ParallelFlowable<T> source, Function<? super T, ? extends R> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelMapTryConditionalSubscriber
(ConditionalSubscriber<? super R> actual, Function<? super T, ? extends R> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelMapTrySubscriber
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends R> mapper, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) -
Uses of Function in io.reactivex.rxjava3.internal.operators.single
Classes in io.reactivex.rxjava3.internal.operators.single that implement FunctionModifier and TypeClassDescription(package private) static enum
(package private) final class
(package private) final class
Fields in io.reactivex.rxjava3.internal.operators.single declared as FunctionModifier and TypeFieldDescription(package private) final Function
<? super T, ? extends SingleSource<? extends R>> SingleFlatMap.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> SingleFlatMap.SingleFlatMapCallback.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends U>> SingleFlatMapBiSelector.FlatMapBiMainObserver.mapper
(package private) final Function
<? super T, ? extends SingleSource<? extends U>> SingleFlatMapBiSelector.mapper
(package private) final Function
<? super T, ? extends CompletableSource> SingleFlatMapCompletable.FlatMapCompletableObserver.mapper
(package private) final Function
<? super T, ? extends CompletableSource> SingleFlatMapCompletable.mapper
SingleFlatMapIterableFlowable.FlatMapIterableObserver.mapper
SingleFlatMapIterableFlowable.mapper
SingleFlatMapIterableObservable.FlatMapIterableObserver.mapper
SingleFlatMapIterableObservable.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> SingleFlatMapMaybe.FlatMapSingleObserver.mapper
(package private) final Function
<? super T, ? extends MaybeSource<? extends R>> SingleFlatMapMaybe.mapper
SingleFlatMapPublisher.mapper
SingleFlatMapPublisher.SingleFlatMapPublisherObserver.mapper
SingleMap.mapper
SingleMap.MapSingleObserver.mapper
(package private) final Function
<? super Throwable, ? extends SingleSource<? extends T>> SingleResumeNext.nextFunction
(package private) final Function
<? super Throwable, ? extends SingleSource<? extends T>> SingleResumeNext.ResumeMainSingleObserver.nextFunction
(package private) final Function
<? super Throwable, ? extends SingleSource<? extends R>> SingleFlatMapNotification.FlatMapSingleObserver.onErrorMapper
(package private) final Function
<? super Throwable, ? extends SingleSource<? extends R>> SingleFlatMapNotification.onErrorMapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> SingleFlatMapNotification.FlatMapSingleObserver.onSuccessMapper
(package private) final Function
<? super T, ? extends SingleSource<? extends R>> SingleFlatMapNotification.onSuccessMapper
(package private) final Function
<? super T, Notification<R>> SingleDematerialize.DematerializeObserver.selector
(package private) final Function
<? super T, Notification<R>> SingleDematerialize.selector
(package private) final Function
<? super U, ? extends SingleSource<? extends T>> SingleUsing.singleFunction
SingleOnErrorReturn.valueSupplier
SingleZipArray.ZipCoordinator.zipper
SingleZipArray.zipper
SingleZipIterable.zipper
Methods in io.reactivex.rxjava3.internal.operators.single that return FunctionModifier and TypeMethodDescriptionstatic <T> Function
<SingleSource<? extends T>, org.reactivestreams.Publisher<? extends T>> SingleInternalHelper.toFlowable()
Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type FunctionModifierConstructorDescription(package private)
DematerializeObserver
(MaybeObserver<? super R> downstream, Function<? super T, Notification<R>> selector) (package private)
FlatMapBiMainObserver
(SingleObserver<? super R> actual, Function<? super T, ? extends SingleSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector) (package private)
FlatMapCompletableObserver
(CompletableObserver actual, Function<? super T, ? extends CompletableSource> mapper) (package private)
FlatMapIterableObserver
(org.reactivestreams.Subscriber<? super R> actual, Function<? super T, ? extends Iterable<? extends R>> mapper) (package private)
FlatMapIterableObserver
(Observer<? super R> actual, Function<? super T, ? extends Iterable<? extends R>> mapper) (package private)
FlatMapSingleObserver
(MaybeObserver<? super R> actual, Function<? super T, ? extends MaybeSource<? extends R>> mapper) (package private)
FlatMapSingleObserver
(SingleObserver<? super R> actual, Function<? super T, ? extends SingleSource<? extends R>> onSuccessMapper, Function<? super Throwable, ? extends SingleSource<? extends R>> onErrorMapper) (package private)
MapSingleObserver
(SingleObserver<? super R> t, Function<? super T, ? extends R> mapper) (package private)
ResumeMainSingleObserver
(SingleObserver<? super T> actual, Function<? super Throwable, ? extends SingleSource<? extends T>> nextFunction) SingleDematerialize
(Single<T> source, Function<? super T, Notification<R>> selector) SingleFlatMap
(SingleSource<? extends T> source, Function<? super T, ? extends SingleSource<? extends R>> mapper) SingleFlatMapBiSelector
(SingleSource<T> source, Function<? super T, ? extends SingleSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector) (package private)
SingleFlatMapCallback
(SingleObserver<? super R> actual, Function<? super T, ? extends SingleSource<? extends R>> mapper) SingleFlatMapCompletable
(SingleSource<T> source, Function<? super T, ? extends CompletableSource> mapper) SingleFlatMapIterableFlowable
(SingleSource<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper) SingleFlatMapIterableObservable
(SingleSource<T> source, Function<? super T, ? extends Iterable<? extends R>> mapper) SingleFlatMapMaybe
(SingleSource<? extends T> source, Function<? super T, ? extends MaybeSource<? extends R>> mapper) SingleFlatMapNotification
(SingleSource<T> source, Function<? super T, ? extends SingleSource<? extends R>> onSuccessMapper, Function<? super Throwable, ? extends SingleSource<? extends R>> onErrorMapper) SingleFlatMapPublisher
(SingleSource<T> source, Function<? super T, ? extends org.reactivestreams.Publisher<? extends R>> mapper) (package private)
SingleFlatMapPublisherObserver
(org.reactivestreams.Subscriber<? super T> actual, Function<? super S, ? extends org.reactivestreams.Publisher<? extends T>> mapper) SingleOnErrorReturn
(SingleSource<? extends T> source, Function<? super Throwable, ? extends T> valueSupplier, T value) SingleResumeNext
(SingleSource<? extends T> source, Function<? super Throwable, ? extends SingleSource<? extends T>> nextFunction) SingleUsing
(Supplier<U> resourceSupplier, Function<? super U, ? extends SingleSource<? extends T>> singleFunction, Consumer<? super U> disposer, boolean eager) SingleZipArray
(SingleSource<? extends T>[] sources, Function<? super Object[], ? extends R> zipper) SingleZipIterable
(Iterable<? extends SingleSource<? extends T>> sources, Function<? super Object[], ? extends R> zipper) (package private)
ZipCoordinator
(SingleObserver<? super R> observer, int n, Function<? super Object[], ? extends R> zipper) -
Uses of Function in io.reactivex.rxjava3.internal.schedulers
Classes in io.reactivex.rxjava3.internal.schedulers that implement FunctionModifier and TypeClassDescription(package private) static final class
(package private) static final class
Methods in io.reactivex.rxjava3.internal.schedulers with parameters of type FunctionModifier and TypeMethodDescription(package private) static boolean
SchedulerPoolFactory.getBooleanProperty
(boolean enabled, String key, boolean defaultNotFound, boolean defaultNotEnabled, Function<String, String> propertyAccessor) Constructors in io.reactivex.rxjava3.internal.schedulers with parameters of type FunctionModifierConstructorDescriptionSchedulerWhen
(Function<Flowable<Flowable<Completable>>, Completable> combine, Scheduler actualScheduler) -
Uses of Function in io.reactivex.rxjava3.internal.util
Classes in io.reactivex.rxjava3.internal.util that implement FunctionMethods in io.reactivex.rxjava3.internal.util that return Function -
Uses of Function in io.reactivex.rxjava3.parallel
Methods in io.reactivex.rxjava3.parallel with parameters of type FunctionModifier and TypeMethodDescriptionfinal <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.concatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Generates and concatenatesPublisher
s on each 'rail', signalling errors immediately and generating 2 publishers upfront.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.concatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int prefetch) Generates and concatenatesPublisher
s on each 'rail', signalling errors immediately and using the given prefetch amount for generatingPublisher
s upfront.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.concatMapDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean tillTheEnd) Generates and concatenatesPublisher
s on each 'rail', optionally delaying errors and generating 2 publishers upfront.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.concatMapDelayError
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, int prefetch, boolean tillTheEnd) Generates and concatenatesPublisher
s on each 'rail', optionally delaying errors and using the given prefetch amount for generatingPublisher
s upfront.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper) Generates and flattensPublisher
s on each 'rail'.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayError) Generates and flattensPublisher
s on each 'rail', optionally delaying errors.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayError, int maxConcurrency) Generates and flattensPublisher
s on each 'rail', optionally delaying errors and having a total number of simultaneous subscriptions to the innerPublisher
s.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMap
(@NonNull Function<? super @NonNull T, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull R>> mapper, boolean delayError, int maxConcurrency, int prefetch) Generates and flattensPublisher
s on each 'rail', optionally delaying errors, having a total number of simultaneous subscriptions to the innerPublisher
s and using the given prefetch amount for the innerPublisher
s.final <@NonNull U>
@NonNull ParallelFlowable<U> ParallelFlowable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper) Returns aParallelFlowable
that merges each item emitted by the source on each rail with the values in anIterable
corresponding to that item that is generated by a selector.final <@NonNull U>
@NonNull ParallelFlowable<U> ParallelFlowable.flatMapIterable
(@NonNull Function<? super @NonNull T, @NonNull ? extends Iterable<? extends @NonNull U>> mapper, int bufferSize) Returns aParallelFlowable
that merges each item emitted by the sourceParallelFlowable
with the values in anIterable
corresponding to that item that is generated by a selector.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper) Maps each upstream item on each rail into aStream
and emits theStream
's items to the downstream in a sequential fashion.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.flatMapStream
(@NonNull Function<? super @NonNull T, @NonNull ? extends Stream<? extends @NonNull R>> mapper, int prefetch) Maps each upstream item of each rail into aStream
and emits theStream
's items to the downstream in a sequential fashion.final <@NonNull R>
@NonNull ParallelFlowable<R> Maps the source values on each 'rail' to another value.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.map
(@NonNull Function<? super @NonNull T, ? extends @NonNull R> mapper, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Maps the source values on each 'rail' to another value and handles errors based on the returned value by the handler function.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.map
(@NonNull Function<? super @NonNull T, ? extends @NonNull R> mapper, @NonNull ParallelFailureHandling errorHandler) Maps the source values on each 'rail' to another value and handles errors based on the givenParallelFailureHandling
enumeration value.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper) Maps the source values on each 'rail' to an optional and emits its value if any.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Maps the source values on each 'rail' to an optional and emits its value if any and handles errors based on the returned value by the handler function.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.mapOptional
(@NonNull Function<? super @NonNull T, @NonNull Optional<? extends @NonNull R>> mapper, @NonNull ParallelFailureHandling errorHandler) Maps the source values on each 'rail' to an optional and emits its value if any and handles errors based on the givenParallelFailureHandling
enumeration value. -
Uses of Function in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins declared as FunctionModifier and TypeFieldDescription(package private) static @Nullable Function
<? super Completable, ? extends Completable> RxJavaPlugins.onCompletableAssembly
RxJavaPlugins.onComputationHandler
(package private) static @Nullable Function
<? super ConnectableFlowable, ? extends ConnectableFlowable> RxJavaPlugins.onConnectableFlowableAssembly
(package private) static @Nullable Function
<? super ConnectableObservable, ? extends ConnectableObservable> RxJavaPlugins.onConnectableObservableAssembly
RxJavaPlugins.onFlowableAssembly
RxJavaPlugins.onInitComputationHandler
RxJavaPlugins.onInitIoHandler
RxJavaPlugins.onInitNewThreadHandler
RxJavaPlugins.onInitSingleHandler
RxJavaPlugins.onIoHandler
RxJavaPlugins.onMaybeAssembly
RxJavaPlugins.onNewThreadHandler
(package private) static @Nullable Function
<? super Observable, ? extends Observable> RxJavaPlugins.onObservableAssembly
(package private) static @Nullable Function
<? super ParallelFlowable, ? extends ParallelFlowable> RxJavaPlugins.onParallelAssembly
RxJavaPlugins.onScheduleHandler
RxJavaPlugins.onSingleAssembly
RxJavaPlugins.onSingleHandler
Methods in io.reactivex.rxjava3.plugins that return FunctionModifier and TypeMethodDescriptionRxJavaPlugins.getComputationSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitComputationSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitIoSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitNewThreadSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getInitSingleSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getIoSchedulerHandler()
Returns the current hook function.RxJavaPlugins.getNewThreadSchedulerHandler()
Returns the current hook function.static @Nullable Function
<? super Completable, ? extends Completable> RxJavaPlugins.getOnCompletableAssembly()
Returns the current hook function.static @Nullable Function
<? super ConnectableFlowable, ? extends ConnectableFlowable> RxJavaPlugins.getOnConnectableFlowableAssembly()
Returns the current hook function.static @Nullable Function
<? super ConnectableObservable, ? extends ConnectableObservable> RxJavaPlugins.getOnConnectableObservableAssembly()
Returns the current hook function.RxJavaPlugins.getOnFlowableAssembly()
Returns the current hook function.RxJavaPlugins.getOnMaybeAssembly()
Returns the current hook function.static @Nullable Function
<? super Observable, ? extends Observable> RxJavaPlugins.getOnObservableAssembly()
Returns the current hook function.static @Nullable Function
<? super ParallelFlowable, ? extends ParallelFlowable> RxJavaPlugins.getOnParallelAssembly()
Returns the current hook function.RxJavaPlugins.getOnSingleAssembly()
Returns the current hook function.RxJavaPlugins.getScheduleHandler()
Returns the current hook function.RxJavaPlugins.getSingleSchedulerHandler()
Returns the current hook function.Methods in io.reactivex.rxjava3.plugins with parameters of type FunctionModifier and TypeMethodDescriptionWraps the call to the function in try-catch and propagates thrown checked exceptions as RuntimeException.RxJavaPlugins.applyRequireNonNull
(@NonNull Function<? super Supplier<Scheduler>, ? extends Scheduler> f, Supplier<Scheduler> s) Wraps the call to the Scheduler creation function in try-catch and propagates thrown checked exceptions as RuntimeException and enforces that result is not null.static void
RxJavaPlugins.setComputationSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitComputationSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitIoSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitNewThreadSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setInitSingleSchedulerHandler
(@Nullable Function<? super Supplier<Scheduler>, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setIoSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setNewThreadSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function.static void
RxJavaPlugins.setOnCompletableAssembly
(@Nullable Function<? super Completable, ? extends Completable> onCompletableAssembly) Sets the specific hook function.static void
RxJavaPlugins.setOnConnectableFlowableAssembly
(@Nullable Function<? super ConnectableFlowable, ? extends ConnectableFlowable> onConnectableFlowableAssembly) Sets the specific hook function.static void
RxJavaPlugins.setOnConnectableObservableAssembly
(@Nullable Function<? super ConnectableObservable, ? extends ConnectableObservable> onConnectableObservableAssembly) Sets the specific hook function.static void
RxJavaPlugins.setOnFlowableAssembly
(@Nullable Function<? super Flowable, ? extends Flowable> onFlowableAssembly) Sets the specific hook function.static void
RxJavaPlugins.setOnMaybeAssembly
(@Nullable Function<? super Maybe, ? extends Maybe> onMaybeAssembly) Sets the specific hook function.static void
RxJavaPlugins.setOnObservableAssembly
(@Nullable Function<? super Observable, ? extends Observable> onObservableAssembly) Sets the specific hook function.static void
RxJavaPlugins.setOnParallelAssembly
(@Nullable Function<? super ParallelFlowable, ? extends ParallelFlowable> handler) Sets the specific hook function.static void
RxJavaPlugins.setOnSingleAssembly
(@Nullable Function<? super Single, ? extends Single> onSingleAssembly) Sets the specific hook function.static void
RxJavaPlugins.setScheduleHandler
(@Nullable Function<? super Runnable, ? extends Runnable> handler) Sets the specific hook function.static void
RxJavaPlugins.setSingleSchedulerHandler
(@Nullable Function<? super Scheduler, ? extends Scheduler> handler) Sets the specific hook function.