Uses of Interface
io.reactivex.rxjava3.functions.BiFunction
Packages that use BiFunction
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 BiFunction in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type BiFunctionModifier and TypeMethodDescriptionFlowable.combineLatest
(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1, @NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> combiner) Combines two sourcePublisher
s by emitting an item that aggregates the latest values of each of the sourcePublisher
s each time an item is received from either of the sourcePublisher
s, where this aggregation is defined by a specified function.static <@NonNull T1,
@NonNull T2, @NonNull R>
@NonNull Observable<R> Observable.combineLatest
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> combiner) Combines two sourceObservableSource
s by emitting an item that aggregates the latest values of each of theObservableSource
s each time an item is received from either of theObservableSource
s, where this aggregation is defined by a specified function.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 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 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 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
.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 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.generate
(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, @NonNull Emitter<@NonNull T>, @NonNull S> generator) Returns a cold, synchronous, stateful and backpressure-aware generator of values.Flowable.generate
(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, @NonNull Emitter<@NonNull T>, @NonNull S> generator, @NonNull Consumer<? super @NonNull S> disposeState) Returns a cold, synchronous, stateful and backpressure-aware generator of values.static <@NonNull T,
@NonNull S>
@NonNull Observable<T> Observable.generate
(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, Emitter<@NonNull T>, @NonNull S> generator) Returns a cold, synchronous and stateful generator of values.static <@NonNull T,
@NonNull S>
@NonNull Observable<T> Observable.generate
(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, Emitter<@NonNull T>, @NonNull S> generator, @NonNull Consumer<? super @NonNull S> disposeState) Returns a cold, synchronous and stateful generator of values.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.Flowable.onBackpressureReduce
(@NonNull BiFunction<@NonNull T, @NonNull T, @NonNull T> reducer) Reduces a sequence of two not emitted values via a function into a single value if the downstream is not ready to receive new items (indicated by a lack ofSubscription.request(long)
calls from it) and emits this latest item when the downstream becomes ready.Flowable.onBackpressureReduce
(@NonNull Supplier<@NonNull R> supplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> reducer) Reduces upstream values into an aggregate value, provided by a supplier and combined via a reducer function, while the downstream is not ready to receive items, then emits this aggregate value when the downstream becomes ready.Returns aMaybe
that applies a specified accumulator function to the first item emitted by the currentFlowable
, then feeds the result of that function along with the second item emitted by the currentFlowable
into the same function, and so on until all items have been emitted by the current and finiteFlowable
, and emits the final result from the final call to your function as its sole item.Flowable.reduce
(@NonNull R seed, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> reducer) Returns aSingle
that applies a specified accumulator function to the first item emitted by the currentFlowable
and a specified seed value, then feeds the result of that function along with the second item emitted by the currentFlowable
into the same function, and so on until all items have been emitted by the current and finiteFlowable
, emitting the final result from the final call to your function as its sole item.Returns aMaybe
that applies a specified accumulator function to the first item emitted by the currentObservable
, then feeds the result of that function along with the second item emitted by the currentObservable
into the same function, and so on until all items have been emitted by the current and finiteObservable
, and emits the final result from the final call to your function as its sole item.Observable.reduce
(@NonNull R seed, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> reducer) Returns aSingle
that applies a specified accumulator function to the first item emitted by the currentObservable
and a specified seed value, then feeds the result of that function along with the second item emitted by the currentObservable
into the same function, and so on until all items have been emitted by the current and finiteObservable
, emitting the final result from the final call to your function as its sole item.Flowable.reduceWith
(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> reducer) Returns aSingle
that applies a specified accumulator function to the first item emitted by the currentFlowable
and a seed value derived from calling a specifiedseedSupplier
, then feeds the result of that function along with the second item emitted by the currentFlowable
into the same function, and so on until all items have been emitted by the current and finiteFlowable
, emitting the final result from the final call to your function as its sole item.Observable.reduceWith
(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> reducer) Returns aSingle
that applies a specified accumulator function to the first item emitted by the currentObservable
and a seed value derived from calling a specifiedseedSupplier
, then feeds the result of that function along with the second item emitted by the currentObservable
into the same function, and so on until all items have been emitted by the current and finiteObservable
, emitting the final result from the final call to your function as its sole item.Returns aFlowable
that emits the first value emitted by the currentFlowable
, then emits one value for each subsequent value emitted by the currentFlowable
.Flowable.scan
(@NonNull R initialValue, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> accumulator) Returns aFlowable
that emits the provided initial (seed) value, then emits one value for each value emitted by the currentFlowable
.final @NonNull Observable
<T> Returns anObservable
that emits the first value emitted by the currentObservable
, then emits one value for each subsequent value emitted by the currentObservable
.final <@NonNull R>
@NonNull Observable<R> Observable.scan
(@NonNull R initialValue, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> accumulator) Returns anObservable
that emits the provided initial (seed) value, then emits one value for each value emitted by the currentObservable
.Flowable.scanWith
(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> accumulator) Returns aFlowable
that emits the provided initial (seed) value, then emits one value for each value emitted by the currentFlowable
.final <@NonNull R>
@NonNull Observable<R> Observable.scanWith
(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> accumulator) Returns anObservable
that emits the provided initial (seed) value, then emits one value for each value emitted by the currentObservable
.Flowable.withLatestFrom
(@NonNull org.reactivestreams.Publisher<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner) Merges the specifiedPublisher
into the currentFlowable
sequence by using theresultSelector
function only when the currentFlowable
(this instance) emits an item.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.withLatestFrom
(@NonNull ObservableSource<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> combiner) Merges the specifiedObservableSource
into the currentObservable
sequence by using theresultSelector
function only when the currentObservable
emits an item.Flowable.zip
(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1, @NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper) Returns aFlowable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherPublisher
s.Flowable.zip
(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1, @NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper, boolean delayError) Returns aFlowable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherPublisher
s.Flowable.zip
(@NonNull org.reactivestreams.Publisher<? extends @NonNull T1> source1, @NonNull org.reactivestreams.Publisher<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper, boolean delayError, int bufferSize) Returns aFlowable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherPublisher
s.Maybe.zip
(@NonNull MaybeSource<? extends @NonNull T1> source1, @NonNull MaybeSource<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper) Returns aMaybe
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherMaybeSource
s.static <@NonNull T1,
@NonNull T2, @NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper) Returns anObservable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherObservableSource
s.static <@NonNull T1,
@NonNull T2, @NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper, boolean delayError) Returns anObservable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherObservableSource
s.static <@NonNull T1,
@NonNull T2, @NonNull R>
@NonNull Observable<R> Observable.zip
(@NonNull ObservableSource<? extends @NonNull T1> source1, @NonNull ObservableSource<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper, boolean delayError, int bufferSize) Returns anObservable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherObservableSource
s.Single.zip
(@NonNull SingleSource<? extends @NonNull T1> source1, @NonNull SingleSource<? extends @NonNull T2> source2, @NonNull BiFunction<? super @NonNull T1, ? super @NonNull T2, ? extends @NonNull R> zipper) Returns aSingle
that emits the results of a specified combiner function applied to two items emitted by two otherSingleSource
s.Flowable.zipWith
(@NonNull Iterable<@NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper) Returns aFlowable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentFlowable
and a specifiedIterable
sequence.Flowable.zipWith
(@NonNull org.reactivestreams.Publisher<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper) Returns aFlowable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentFlowable
and another specifiedPublisher
.Flowable.zipWith
(@NonNull org.reactivestreams.Publisher<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper, boolean delayError) Returns aFlowable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentFlowable
and another specifiedPublisher
.Flowable.zipWith
(@NonNull org.reactivestreams.Publisher<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper, boolean delayError, int bufferSize) Returns aFlowable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentFlowable
and another specifiedPublisher
.Maybe.zipWith
(@NonNull MaybeSource<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper) Waits until this and the otherMaybeSource
signal a success value then applies the givenBiFunction
to those values and emits theBiFunction
's resulting value to downstream.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.zipWith
(@NonNull ObservableSource<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper) Returns anObservable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentObservable
and another specifiedObservableSource
.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.zipWith
(@NonNull ObservableSource<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper, boolean delayError) Returns anObservable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentObservable
and another specifiedObservableSource
.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.zipWith
(@NonNull ObservableSource<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper, boolean delayError, int bufferSize) Returns anObservable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentObservable
and another specifiedObservableSource
.final <@NonNull U,
@NonNull R>
@NonNull Observable<R> Observable.zipWith
(@NonNull Iterable<@NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper) Returns anObservable
that emits items that are the result of applying a specified function to pairs of values, one each from the currentObservable
and a specifiedIterable
sequence.Single.zipWith
(@NonNull SingleSource<@NonNull U> other, @NonNull BiFunction<? super @NonNull T, ? super @NonNull U, ? extends @NonNull R> zipper) Returns aSingle
that emits the result of applying a specified function to the pair of items emitted by the currentSingle
and another specifiedSingleSource
. -
Uses of BiFunction in io.reactivex.rxjava3.internal.functions
Fields in io.reactivex.rxjava3.internal.functions declared as BiFunctionModifier and TypeFieldDescription(package private) final BiFunction
<? super T1, ? super T2, ? extends R> Functions.Array2Func.f
Methods in io.reactivex.rxjava3.internal.functions with parameters of type BiFunctionModifier and TypeMethodDescriptionFunctions.toFunction
(@NonNull BiFunction<? super T1, ? super T2, ? extends R> f) Constructors in io.reactivex.rxjava3.internal.functions with parameters of type BiFunctionModifierConstructorDescription(package private)
Array2Func
(BiFunction<? super T1, ? super T2, ? extends R> f) -
Uses of BiFunction in io.reactivex.rxjava3.internal.jdk8
Fields in io.reactivex.rxjava3.internal.jdk8 declared as BiFunctionModifier and TypeFieldDescription(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTryOptional.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTryOptional.ParallelMapTryConditionalSubscriber.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTryOptional.ParallelMapTrySubscriber.errorHandler
Constructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type BiFunctionModifierConstructorDescription(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) -
Uses of BiFunction in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement BiFunctionModifier and TypeClassDescription(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as BiFunctionModifier and TypeFieldDescription(package private) final BiFunction
<T, T, T> FlowableScan.accumulator
(package private) final BiFunction
<T, T, T> FlowableScan.ScanSubscriber.accumulator
(package private) final BiFunction
<R, ? super T, R> FlowableScanSeed.accumulator
(package private) final BiFunction
<R, ? super T, R> FlowableScanSeed.ScanSeedSubscriber.accumulator
private final BiFunction
<? super T, ? super U, ? extends R> FlowableInternalHelper.FlatMapWithCombinerInner.combiner
private final BiFunction
<? super T, ? super U, ? extends R> FlowableInternalHelper.FlatMapWithCombinerOuter.combiner
(package private) final BiFunction
<? super T, ? super U, ? extends R> FlowableWithLatestFrom.combiner
(package private) final BiFunction
<? super T, ? super U, ? extends R> FlowableWithLatestFrom.WithLatestFromSubscriber.combiner
(package private) final BiFunction
<S, Emitter<T>, S> FlowableGenerate.generator
(package private) final BiFunction
<S, ? super Emitter<T>, S> FlowableGenerate.GeneratorSubscription.generator
(package private) final BiFunction
<T, T, T> FlowableOnBackpressureReduce.BackpressureReduceSubscriber.reducer
(package private) final BiFunction
<T, T, T> FlowableOnBackpressureReduce.reducer
(package private) final BiFunction
<R, ? super T, R> FlowableOnBackpressureReduceWith.BackpressureReduceWithSubscriber.reducer
(package private) final BiFunction
<R, ? super T, R> FlowableOnBackpressureReduceWith.reducer
(package private) final BiFunction
<T, T, T> FlowableReduce.reducer
(package private) final BiFunction
<T, T, T> FlowableReduce.ReduceSubscriber.reducer
(package private) final BiFunction
<T, T, T> FlowableReduceMaybe.reducer
(package private) final BiFunction
<T, T, T> FlowableReduceMaybe.ReduceSubscriber.reducer
(package private) final BiFunction
<R, ? super T, R> FlowableReduceSeedSingle.reducer
(package private) final BiFunction
<R, ? super T, R> FlowableReduceSeedSingle.ReduceSeedObserver.reducer
(package private) final BiFunction
<R, ? super T, R> FlowableReduceWithSingle.reducer
(package private) final BiFunction
<? super TLeft, ? super Flowable<TRight>, ? extends R> FlowableGroupJoin.GroupJoinSubscription.resultSelector
(package private) final BiFunction
<? super TLeft, ? super Flowable<TRight>, ? extends R> FlowableGroupJoin.resultSelector
(package private) final BiFunction
<? super TLeft, ? super TRight, ? extends R> FlowableJoin.JoinSubscription.resultSelector
(package private) final BiFunction
<? super TLeft, ? super TRight, ? extends R> FlowableJoin.resultSelector
(package private) final BiFunction
<? super T, ? super U, ? extends V> FlowableZipIterable.ZipIterableSubscriber.zipper
(package private) final BiFunction
<? super T, ? super U, ? extends V> FlowableZipIterable.zipper
Methods in io.reactivex.rxjava3.internal.operators.flowable that return BiFunctionModifier and TypeMethodDescriptionstatic <T,
S> BiFunction <S, Emitter<T>, S> FlowableInternalHelper.simpleBiGenerator
(BiConsumer<S, Emitter<T>> consumer) static <T,
S> BiFunction <S, Emitter<T>, S> FlowableInternalHelper.simpleGenerator
(Consumer<Emitter<T>> consumer) Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type BiFunctionModifier and TypeMethodDescriptionstatic <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) Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type BiFunctionModifierConstructorDescription(package private)
BackpressureReduceSubscriber
(@NonNull org.reactivestreams.Subscriber<? super T> downstream, @NonNull BiFunction<T, T, T> reducer) (package private)
BackpressureReduceWithSubscriber
(@NonNull org.reactivestreams.Subscriber<? super R> downstream, @NonNull Supplier<R> supplier, @NonNull BiFunction<R, ? super T, R> reducer) (package private)
FlatMapWithCombinerInner
(BiFunction<? super T, ? super U, ? extends R> combiner, T t) (package private)
FlatMapWithCombinerOuter
(BiFunction<? super T, ? super U, ? extends R> combiner, Function<? super T, ? extends org.reactivestreams.Publisher<? extends U>> mapper) FlowableGenerate
(Supplier<S> stateSupplier, BiFunction<S, Emitter<T>, S> generator, Consumer<? super S> disposeState) 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) FlowableOnBackpressureReduce
(@NonNull Flowable<T> source, @NonNull BiFunction<T, T, T> reducer) FlowableOnBackpressureReduceWith
(@NonNull Flowable<T> source, @NonNull Supplier<R> supplier, @NonNull BiFunction<R, ? super T, R> reducer) FlowableReduce
(Flowable<T> source, BiFunction<T, T, T> reducer) FlowableReduceMaybe
(Flowable<T> source, BiFunction<T, T, T> reducer) FlowableReduceSeedSingle
(org.reactivestreams.Publisher<T> source, R seed, BiFunction<R, ? super T, R> reducer) FlowableReduceWithSingle
(org.reactivestreams.Publisher<T> source, Supplier<R> seedSupplier, BiFunction<R, ? super T, R> reducer) FlowableScan
(Flowable<T> source, BiFunction<T, T, T> accumulator) FlowableScanSeed
(Flowable<T> source, Supplier<R> seedSupplier, BiFunction<R, ? super T, R> accumulator) FlowableWithLatestFrom
(Flowable<T> source, BiFunction<? super T, ? super U, ? extends R> combiner, org.reactivestreams.Publisher<? extends U> other) FlowableZipIterable
(Flowable<T> source, Iterable<U> other, BiFunction<? super T, ? super U, ? extends V> zipper) (package private)
GeneratorSubscription
(org.reactivestreams.Subscriber<? super T> actual, BiFunction<S, ? super Emitter<T>, S> generator, Consumer<? super S> disposeState, S initialState) (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)
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)
ReduceSeedObserver
(SingleObserver<? super R> actual, BiFunction<R, ? super T, R> reducer, R value) (package private)
ReduceSubscriber
(org.reactivestreams.Subscriber<? super T> actual, BiFunction<T, T, T> reducer) (package private)
ReduceSubscriber
(MaybeObserver<? super T> actual, BiFunction<T, T, T> reducer) (package private)
ScanSeedSubscriber
(org.reactivestreams.Subscriber<? super R> actual, BiFunction<R, ? super T, R> accumulator, R value, int prefetch) (package private)
ScanSubscriber
(org.reactivestreams.Subscriber<? super T> actual, BiFunction<T, T, T> accumulator) (package private)
WithLatestFromSubscriber
(org.reactivestreams.Subscriber<? super R> actual, BiFunction<? super T, ? super U, ? extends R> combiner) (package private)
ZipIterableSubscriber
(org.reactivestreams.Subscriber<? super V> actual, Iterator<U> iterator, BiFunction<? super T, ? super U, ? extends V> zipper) -
Uses of BiFunction in io.reactivex.rxjava3.internal.operators.maybe
Fields in io.reactivex.rxjava3.internal.operators.maybe declared as BiFunctionModifier and TypeFieldDescription(package private) final BiFunction
<? super T, ? super U, ? extends R> MaybeFlatMapBiSelector.FlatMapBiMainObserver.InnerObserver.resultSelector
(package private) final BiFunction
<? super T, ? super U, ? extends R> MaybeFlatMapBiSelector.resultSelector
Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type BiFunctionModifierConstructorDescription(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)
InnerObserver
(MaybeObserver<? super R> actual, BiFunction<? super T, ? super U, ? extends R> resultSelector) MaybeFlatMapBiSelector
(MaybeSource<T> source, Function<? super T, ? extends MaybeSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector) -
Uses of BiFunction in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement BiFunctionModifier and TypeClassDescription(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.observable declared as BiFunctionModifier and TypeFieldDescription(package private) final BiFunction
<T, T, T> ObservableScan.accumulator
(package private) final BiFunction
<T, T, T> ObservableScan.ScanObserver.accumulator
(package private) final BiFunction
<R, ? super T, R> ObservableScanSeed.accumulator
(package private) final BiFunction
<R, ? super T, R> ObservableScanSeed.ScanSeedObserver.accumulator
private final BiFunction
<? super T, ? super U, ? extends R> ObservableInternalHelper.FlatMapWithCombinerInner.combiner
private final BiFunction
<? super T, ? super U, ? extends R> ObservableInternalHelper.FlatMapWithCombinerOuter.combiner
(package private) final BiFunction
<? super T, ? super U, ? extends R> ObservableWithLatestFrom.combiner
(package private) final BiFunction
<? super T, ? super U, ? extends R> ObservableWithLatestFrom.WithLatestFromObserver.combiner
(package private) final BiFunction
<S, Emitter<T>, S> ObservableGenerate.generator
(package private) final BiFunction
<S, ? super Emitter<T>, S> ObservableGenerate.GeneratorDisposable.generator
(package private) final BiFunction
<T, T, T> ObservableReduceMaybe.ReduceObserver.reducer
(package private) final BiFunction
<T, T, T> ObservableReduceMaybe.reducer
(package private) final BiFunction
<R, ? super T, R> ObservableReduceSeedSingle.reducer
(package private) final BiFunction
<R, ? super T, R> ObservableReduceSeedSingle.ReduceSeedObserver.reducer
(package private) final BiFunction
<R, ? super T, R> ObservableReduceWithSingle.reducer
(package private) final BiFunction
<? super TLeft, ? super Observable<TRight>, ? extends R> ObservableGroupJoin.GroupJoinDisposable.resultSelector
(package private) final BiFunction
<? super TLeft, ? super Observable<TRight>, ? extends R> ObservableGroupJoin.resultSelector
(package private) final BiFunction
<? super TLeft, ? super TRight, ? extends R> ObservableJoin.JoinDisposable.resultSelector
(package private) final BiFunction
<? super TLeft, ? super TRight, ? extends R> ObservableJoin.resultSelector
(package private) final BiFunction
<? super T, ? super U, ? extends V> ObservableZipIterable.ZipIterableObserver.zipper
(package private) final BiFunction
<? super T, ? super U, ? extends V> ObservableZipIterable.zipper
Methods in io.reactivex.rxjava3.internal.operators.observable that return BiFunctionModifier and TypeMethodDescriptionstatic <T,
S> BiFunction <S, Emitter<T>, S> ObservableInternalHelper.simpleBiGenerator
(BiConsumer<S, Emitter<T>> consumer) static <T,
S> BiFunction <S, Emitter<T>, S> ObservableInternalHelper.simpleGenerator
(Consumer<Emitter<T>> consumer) Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type BiFunctionModifier and TypeMethodDescriptionstatic <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) Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type BiFunctionModifierConstructorDescription(package private)
FlatMapWithCombinerInner
(BiFunction<? super T, ? super U, ? extends R> combiner, T t) (package private)
FlatMapWithCombinerOuter
(BiFunction<? super T, ? super U, ? extends R> combiner, Function<? super T, ? extends ObservableSource<? extends U>> mapper) (package private)
GeneratorDisposable
(Observer<? super T> actual, BiFunction<S, ? super Emitter<T>, S> generator, Consumer<? super S> disposeState, S initialState) (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)
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) ObservableGenerate
(Supplier<S> stateSupplier, BiFunction<S, Emitter<T>, S> generator, Consumer<? super S> disposeState) 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) ObservableReduceMaybe
(ObservableSource<T> source, BiFunction<T, T, T> reducer) ObservableReduceSeedSingle
(ObservableSource<T> source, R seed, BiFunction<R, ? super T, R> reducer) ObservableReduceWithSingle
(ObservableSource<T> source, Supplier<R> seedSupplier, BiFunction<R, ? super T, R> reducer) ObservableScan
(ObservableSource<T> source, BiFunction<T, T, T> accumulator) ObservableScanSeed
(ObservableSource<T> source, Supplier<R> seedSupplier, BiFunction<R, ? super T, R> accumulator) ObservableWithLatestFrom
(ObservableSource<T> source, BiFunction<? super T, ? super U, ? extends R> combiner, ObservableSource<? extends U> other) ObservableZipIterable
(Observable<? extends T> source, Iterable<U> other, BiFunction<? super T, ? super U, ? extends V> zipper) (package private)
ReduceObserver
(MaybeObserver<? super T> observer, BiFunction<T, T, T> reducer) (package private)
ReduceSeedObserver
(SingleObserver<? super R> actual, BiFunction<R, ? super T, R> reducer, R value) (package private)
ScanObserver
(Observer<? super T> actual, BiFunction<T, T, T> accumulator) (package private)
ScanSeedObserver
(Observer<? super R> actual, BiFunction<R, ? super T, R> accumulator, R value) (package private)
WithLatestFromObserver
(Observer<? super R> actual, BiFunction<? super T, ? super U, ? extends R> combiner) (package private)
ZipIterableObserver
(Observer<? super V> actual, Iterator<U> iterator, BiFunction<? super T, ? super U, ? extends V> zipper) -
Uses of BiFunction in io.reactivex.rxjava3.internal.operators.parallel
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as BiFunctionModifier and TypeFieldDescription(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelDoOnNextTry.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelDoOnNextTry.ParallelDoOnNextConditionalSubscriber.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelDoOnNextTry.ParallelDoOnNextSubscriber.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelFilterTry.BaseFilterSubscriber.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelFilterTry.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTry.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTry.ParallelMapTryConditionalSubscriber.errorHandler
(package private) final BiFunction
<? super Long, ? super Throwable, ParallelFailureHandling> ParallelMapTry.ParallelMapTrySubscriber.errorHandler
(package private) final BiFunction
<R, ? super T, R> ParallelReduce.ParallelReduceSubscriber.reducer
(package private) final BiFunction
<R, ? super T, R> ParallelReduce.reducer
(package private) final BiFunction
<T, T, T> ParallelReduceFull.ParallelReduceFullInnerSubscriber.reducer
(package private) final BiFunction
<T, T, T> ParallelReduceFull.ParallelReduceFullMainSubscriber.reducer
(package private) final BiFunction
<T, T, T> ParallelReduceFull.reducer
Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type BiFunctionModifierConstructorDescription(package private)
BaseFilterSubscriber
(Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelDoOnNextConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelDoOnNextSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) ParallelDoOnNextTry
(ParallelFlowable<T> source, Consumer<? super T> onNext, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelFilterConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelFilterSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) ParallelFilterTry
(ParallelFlowable<T> source, Predicate<? super T> predicate, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) 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) ParallelReduce
(ParallelFlowable<? extends T> source, Supplier<R> initialSupplier, BiFunction<R, ? super T, R> reducer) ParallelReduceFull
(ParallelFlowable<? extends T> source, BiFunction<T, T, T> reducer) (package private)
ParallelReduceFullInnerSubscriber
(ParallelReduceFull.ParallelReduceFullMainSubscriber<T> parent, BiFunction<T, T, T> reducer) (package private)
ParallelReduceFullMainSubscriber
(org.reactivestreams.Subscriber<? super T> subscriber, int n, BiFunction<T, T, T> reducer) (package private)
ParallelReduceSubscriber
(org.reactivestreams.Subscriber<? super R> subscriber, R initialValue, BiFunction<R, ? super T, R> reducer) -
Uses of BiFunction in io.reactivex.rxjava3.internal.operators.single
Fields in io.reactivex.rxjava3.internal.operators.single declared as BiFunctionModifier and TypeFieldDescription(package private) final BiFunction
<? super T, ? super U, ? extends R> SingleFlatMapBiSelector.FlatMapBiMainObserver.InnerObserver.resultSelector
(package private) final BiFunction
<? super T, ? super U, ? extends R> SingleFlatMapBiSelector.resultSelector
Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type BiFunctionModifierConstructorDescription(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)
InnerObserver
(SingleObserver<? super R> actual, BiFunction<? super T, ? super U, ? extends R> resultSelector) SingleFlatMapBiSelector
(SingleSource<T> source, Function<? super T, ? extends SingleSource<? extends U>> mapper, BiFunction<? super T, ? super U, ? extends R> resultSelector) -
Uses of BiFunction in io.reactivex.rxjava3.internal.util
Classes in io.reactivex.rxjava3.internal.util that implement BiFunctionModifier and TypeClassDescriptionenum
final class
A BiFunction that merges two Lists into a new list.Methods in io.reactivex.rxjava3.internal.util that return BiFunctionModifier and TypeMethodDescriptionstatic <T> BiFunction
<List<T>, T, List<T>> ListAddBiConsumer.instance()
-
Uses of BiFunction in io.reactivex.rxjava3.parallel
Classes in io.reactivex.rxjava3.parallel that implement BiFunctionModifier and TypeClassDescriptionenum
Enumerations for handling failure within a parallel operator.Methods in io.reactivex.rxjava3.parallel with parameters of type BiFunctionModifier and TypeMethodDescriptionfinal @NonNull ParallelFlowable
<T> ParallelFlowable.doOnNext
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Call the specified consumer with the current element passing through any 'rail' and handles errors based on the returned value by the handler function.final @NonNull ParallelFlowable
<T> ParallelFlowable.filter
(@NonNull Predicate<? super @NonNull T> predicate, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Filters the source values on each 'rail' 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 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.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.Reduces all values within a 'rail' and across 'rails' with a reducer function into oneFlowable
sequence.final <@NonNull R>
@NonNull ParallelFlowable<R> ParallelFlowable.reduce
(@NonNull Supplier<@NonNull R> initialSupplier, @NonNull BiFunction<@NonNull R, ? super @NonNull T, @NonNull R> reducer) Reduces all values within a 'rail' to a single value (with a possibly different type) via a reducer function that is initialized on each rail from aninitialSupplier
value. -
Uses of BiFunction in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins declared as BiFunctionModifier and TypeFieldDescription(package private) static @Nullable BiFunction
<? super Completable, @NonNull ? super CompletableObserver, @NonNull ? extends CompletableObserver> RxJavaPlugins.onCompletableSubscribe
(package private) static @Nullable BiFunction
<? super Flowable, @NonNull ? super org.reactivestreams.Subscriber, @NonNull ? extends org.reactivestreams.Subscriber> RxJavaPlugins.onFlowableSubscribe
(package private) static @Nullable BiFunction
<? super Maybe, @NonNull ? super MaybeObserver, @NonNull ? extends MaybeObserver> RxJavaPlugins.onMaybeSubscribe
(package private) static @Nullable BiFunction
<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer> RxJavaPlugins.onObservableSubscribe
(package private) static @Nullable BiFunction
<? super ParallelFlowable, @NonNull ? super org.reactivestreams.Subscriber[], @NonNull ? extends org.reactivestreams.Subscriber[]> RxJavaPlugins.onParallelSubscribe
(package private) static @Nullable BiFunction
<? super Single, @NonNull ? super SingleObserver, @NonNull ? extends SingleObserver> RxJavaPlugins.onSingleSubscribe
Methods in io.reactivex.rxjava3.plugins that return BiFunctionModifier and TypeMethodDescriptionstatic @Nullable BiFunction
<? super Completable, @NonNull ? super CompletableObserver, @NonNull ? extends CompletableObserver> RxJavaPlugins.getOnCompletableSubscribe()
Returns the current hook function.static @Nullable BiFunction
<? super Flowable, @NonNull ? super org.reactivestreams.Subscriber, @NonNull ? extends org.reactivestreams.Subscriber> RxJavaPlugins.getOnFlowableSubscribe()
Returns the current hook function.static @Nullable BiFunction
<? super Maybe, @NonNull ? super MaybeObserver, @NonNull ? extends MaybeObserver> RxJavaPlugins.getOnMaybeSubscribe()
Returns the current hook function.static @Nullable BiFunction
<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer> RxJavaPlugins.getOnObservableSubscribe()
Returns the current hook function.static @Nullable BiFunction
<? super ParallelFlowable, @NonNull ? super org.reactivestreams.Subscriber[], @NonNull ? extends org.reactivestreams.Subscriber[]> RxJavaPlugins.getOnParallelSubscribe()
Returns the current hook function.static @Nullable BiFunction
<? super Single, @NonNull ? super SingleObserver, @NonNull ? extends SingleObserver> RxJavaPlugins.getOnSingleSubscribe()
Returns the current hook function.Methods in io.reactivex.rxjava3.plugins with parameters of type BiFunctionModifier and TypeMethodDescriptionRxJavaPlugins.apply
(@NonNull BiFunction<@NonNull T, @NonNull U, @NonNull R> f, @NonNull T t, @NonNull U u) Wraps the call to the function in try-catch and propagates thrown checked exceptions as RuntimeException.static void
RxJavaPlugins.setOnCompletableSubscribe
(@Nullable BiFunction<? super Completable, @NonNull ? super CompletableObserver, @NonNull ? extends CompletableObserver> onCompletableSubscribe) Sets the specific hook function.static void
RxJavaPlugins.setOnFlowableSubscribe
(@Nullable BiFunction<? super Flowable, @NonNull ? super org.reactivestreams.Subscriber, @NonNull ? extends org.reactivestreams.Subscriber> onFlowableSubscribe) Sets the specific hook function.static void
RxJavaPlugins.setOnMaybeSubscribe
(@Nullable BiFunction<? super Maybe, @NonNull MaybeObserver, @NonNull ? extends MaybeObserver> onMaybeSubscribe) Sets the specific hook function.static void
RxJavaPlugins.setOnObservableSubscribe
(@Nullable BiFunction<? super Observable, @NonNull ? super Observer, @NonNull ? extends Observer> onObservableSubscribe) Sets the specific hook function.static void
RxJavaPlugins.setOnParallelSubscribe
(@Nullable BiFunction<? super ParallelFlowable, @NonNull ? super org.reactivestreams.Subscriber[], @NonNull ? extends org.reactivestreams.Subscriber[]> handler) Sets the specific hook function.static void
RxJavaPlugins.setOnSingleSubscribe
(@Nullable BiFunction<? super Single, @NonNull ? super SingleObserver, @NonNull ? extends SingleObserver> onSingleSubscribe) Sets the specific hook function.