Uses of Interface
io.reactivex.rxjava3.functions.BiFunction

Packages that use BiFunction

Package	Description
io.reactivex.rxjava3.core	Base reactive classes: Flowable, Observable, Single, Maybe and Completable; base reactive consumers; other common base interfaces.
io.reactivex.rxjava3.internal.functions
io.reactivex.rxjava3.internal.jdk8
io.reactivex.rxjava3.internal.operators.flowable
io.reactivex.rxjava3.internal.operators.maybe
io.reactivex.rxjava3.internal.operators.observable
io.reactivex.rxjava3.internal.operators.parallel
io.reactivex.rxjava3.internal.operators.single
io.reactivex.rxjava3.internal.util
io.reactivex.rxjava3.parallel	Contains the base type ParallelFlowable, a sub-DSL for working with Flowable sequences in parallel.
io.reactivex.rxjava3.plugins	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 BiFunction

Modifier and Type	Method	Description
static <@NonNull T1,@NonNull T2,@NonNull R> @NonNull Flowable<R>	Flowable.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 source Publishers by emitting an item that aggregates the latest values of each of the source Publishers each time an item is received from either of the source Publishers, 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 source ObservableSources by emitting an item that aggregates the latest values of each of the ObservableSources each time an item is received from either of the ObservableSources, where this aggregation is defined by a specified function.
<@NonNull U,@NonNull R> @NonNull Flowable<R>	Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner)	Returns a Flowable that emits the results of a specified function to the pair of values emitted by the current Flowable and a specified collection Publisher.
<@NonNull U,@NonNull R> @NonNull Flowable<R>	Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner, boolean delayErrors)	Returns a Flowable that emits the results of a specified function to the pair of values emitted by the current Flowable and a specified inner Publisher.
<@NonNull U,@NonNull R> @NonNull Flowable<R>	Flowable.flatMap(@NonNull Function<? super @NonNull T,? 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 a Flowable that emits the results of a specified function to the pair of values emitted by the current Flowable and a specified collection Publisher, while limiting the maximum number of concurrent subscriptions to these Publishers.
<@NonNull U,@NonNull R> @NonNull Flowable<R>	Flowable.flatMap(@NonNull Function<? super @NonNull T,? 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 a Flowable that emits the results of a specified function to the pair of values emitted by the current Flowable and a specified collection Publisher, while limiting the maximum number of concurrent subscriptions to these Publishers.
<@NonNull U,@NonNull R> @NonNull Flowable<R>	Flowable.flatMap(@NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner, int maxConcurrency)	Returns a Flowable that emits the results of a specified function to the pair of values emitted by the current Flowable and a specified collection Publisher, while limiting the maximum number of concurrent subscriptions to these Publishers.
<@NonNull U,@NonNull R> @NonNull Maybe<R>	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 a Maybe that emits the results of a specified function to the pair of values emitted by the current Maybe and a specified mapped MaybeSource.
<@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 an Observable that emits the results of a specified function to the pair of values emitted by the current Observable and the mapped inner ObservableSource.
<@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 an Observable that emits the results of a specified function to the pair of values emitted by the current Observable and the mapped inner ObservableSource.
<@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 an Observable that emits the results of a specified function to the pair of values emitted by the current Observable and the mapped inner ObservableSource, while limiting the maximum number of concurrent subscriptions to these ObservableSources.
<@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 an Observable that emits the results of a specified function to the pair of values emitted by the current Observable and the mapped inner ObservableSource, while limiting the maximum number of concurrent subscriptions to these ObservableSources.
<@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 an Observable that emits the results of a specified function to the pair of values emitted by the current Observable and the mapped inner ObservableSource, while limiting the maximum number of concurrent subscriptions to these ObservableSources.
<@NonNull U,@NonNull R> @NonNull Single<R>	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 a Single that emits the results of a specified function to the pair of values emitted by the current Single and a specified mapped SingleSource.
<@NonNull U,@NonNull V> @NonNull Flowable<V>	Flowable.flatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull V> combiner)	Merges Iterables generated by a mapper Function for each individual item emitted by the current Flowable into a single Flowable sequence where the resulting items will be the combination of the original item and each inner item of the respective Iterable as returned by the resultSelector BiFunction.
<@NonNull U,@NonNull V> @NonNull Flowable<V>	Flowable.flatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull V> combiner, int prefetch)	Merges Iterables generated by a mapper Function for each individual item emitted by the current Flowable into a single Flowable sequence where the resulting items will be the combination of the original item and each inner item of the respective Iterable as returned by the resultSelector BiFunction.
<@NonNull U,@NonNull V> @NonNull Observable<V>	Observable.flatMapIterable(@NonNull Function<? super @NonNull T,? extends java.lang.Iterable<? extends @NonNull U>> mapper, @NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull V> combiner)	Merges Iterables generated by a mapper Function for each individual item emitted by the current Observable into a single Observable sequence where the resulting items will be the combination of the original item and each inner item of the respective Iterable as returned by the resultSelector BiFunction.
static <@NonNull T,@NonNull S> @NonNull Flowable<T>	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.
static <@NonNull T,@NonNull S> @NonNull Flowable<T>	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.
<@NonNull TRight,@NonNull TLeftEnd,@NonNull TRightEnd,@NonNull R> @NonNull Flowable<R>	Flowable.groupJoin(@NonNull org.reactivestreams.Publisher<? extends @NonNull TRight> other, @NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull TLeftEnd>> leftEnd, @NonNull Function<? super @NonNull TRight,? extends org.reactivestreams.Publisher<@NonNull TRightEnd>> rightEnd, @NonNull BiFunction<? super @NonNull T,? super Flowable<@NonNull TRight>,? extends @NonNull R> resultSelector)	Returns a Flowable that correlates two Publishers when they overlap in time and groups the results.
<@NonNull TRight,@NonNull TLeftEnd,@NonNull TRightEnd,@NonNull R> @NonNull Observable<R>	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 an Observable that correlates two ObservableSources when they overlap in time and groups the results.
<@NonNull TRight,@NonNull TLeftEnd,@NonNull TRightEnd,@NonNull R> @NonNull Flowable<R>	Flowable.join(@NonNull org.reactivestreams.Publisher<? extends @NonNull TRight> other, @NonNull Function<? super @NonNull T,? extends org.reactivestreams.Publisher<@NonNull TLeftEnd>> leftEnd, @NonNull Function<? super @NonNull TRight,? extends org.reactivestreams.Publisher<@NonNull TRightEnd>> rightEnd, @NonNull BiFunction<? super @NonNull T,? super @NonNull TRight,? extends @NonNull R> resultSelector)	Correlates the items emitted by two Publishers based on overlapping durations.
<@NonNull TRight,@NonNull TLeftEnd,@NonNull TRightEnd,@NonNull R> @NonNull Observable<R>	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 two ObservableSources based on overlapping durations.
@NonNull Flowable<T>	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 of Subscription.request(long) calls from it) and emits this latest item when the downstream becomes ready.
<@NonNull R> @NonNull Flowable<R>	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.
@NonNull Maybe<T>	Flowable.reduce(@NonNull BiFunction<@NonNull T,@NonNull T,@NonNull T> reducer)	Returns a Maybe that applies a specified accumulator function to the first item emitted by the current Flowable, then feeds the result of that function along with the second item emitted by the current Flowable into the same function, and so on until all items have been emitted by the current and finite Flowable, and emits the final result from the final call to your function as its sole item.
<@NonNull R> @NonNull Single<R>	Flowable.reduce(@NonNull R seed, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> reducer)	Returns a Single that applies a specified accumulator function to the first item emitted by the current Flowable and a specified seed value, then feeds the result of that function along with the second item emitted by the current Flowable into the same function, and so on until all items have been emitted by the current and finite Flowable, emitting the final result from the final call to your function as its sole item.
@NonNull Maybe<T>	Observable.reduce(@NonNull BiFunction<@NonNull T,@NonNull T,@NonNull T> reducer)	Returns a Maybe that applies a specified accumulator function to the first item emitted by the current Observable, then feeds the result of that function along with the second item emitted by the current Observable into the same function, and so on until all items have been emitted by the current and finite Observable, and emits the final result from the final call to your function as its sole item.
<@NonNull R> @NonNull Single<R>	Observable.reduce(@NonNull R seed, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> reducer)	Returns a Single that applies a specified accumulator function to the first item emitted by the current Observable and a specified seed value, then feeds the result of that function along with the second item emitted by the current Observable into the same function, and so on until all items have been emitted by the current and finite Observable, emitting the final result from the final call to your function as its sole item.
<@NonNull R> @NonNull Single<R>	Flowable.reduceWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> reducer)	Returns a Single that applies a specified accumulator function to the first item emitted by the current Flowable and a seed value derived from calling a specified seedSupplier, then feeds the result of that function along with the second item emitted by the current Flowable into the same function, and so on until all items have been emitted by the current and finite Flowable, emitting the final result from the final call to your function as its sole item.
<@NonNull R> @NonNull Single<R>	Observable.reduceWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> reducer)	Returns a Single that applies a specified accumulator function to the first item emitted by the current Observable and a seed value derived from calling a specified seedSupplier, then feeds the result of that function along with the second item emitted by the current Observable into the same function, and so on until all items have been emitted by the current and finite Observable, emitting the final result from the final call to your function as its sole item.
@NonNull Flowable<T>	Flowable.scan(@NonNull BiFunction<@NonNull T,@NonNull T,@NonNull T> accumulator)	Returns a Flowable that emits the first value emitted by the current Flowable, then emits one value for each subsequent value emitted by the current Flowable.
<@NonNull R> @NonNull Flowable<R>	Flowable.scan(@NonNull R initialValue, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> accumulator)	Returns a Flowable that emits the provided initial (seed) value, then emits one value for each value emitted by the current Flowable.
@NonNull Observable<T>	Observable.scan(@NonNull BiFunction<@NonNull T,@NonNull T,@NonNull T> accumulator)	Returns an Observable that emits the first value emitted by the current Observable, then emits one value for each subsequent value emitted by the current Observable.
<@NonNull R> @NonNull Observable<R>	Observable.scan(@NonNull R initialValue, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> accumulator)	Returns an Observable that emits the provided initial (seed) value, then emits one value for each value emitted by the current Observable.
<@NonNull R> @NonNull Flowable<R>	Flowable.scanWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> accumulator)	Returns a Flowable that emits the provided initial (seed) value, then emits one value for each value emitted by the current Flowable.
<@NonNull R> @NonNull Observable<R>	Observable.scanWith(@NonNull Supplier<@NonNull R> seedSupplier, @NonNull BiFunction<@NonNull R,? super @NonNull T,@NonNull R> accumulator)	Returns an Observable that emits the provided initial (seed) value, then emits one value for each value emitted by the current Observable.
<@NonNull U,@NonNull R> @NonNull Flowable<R>	Flowable.withLatestFrom(@NonNull org.reactivestreams.Publisher<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> combiner)	Merges the specified Publisher into the current Flowable sequence by using the resultSelector function only when the current Flowable (this instance) emits an item.
<@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 specified ObservableSource into the current Observable sequence by using the resultSelector function only when the current Observable emits an item.
static <@NonNull T1,@NonNull T2,@NonNull R> @NonNull Flowable<R>	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 a Flowable that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two other Publishers.
static <@NonNull T1,@NonNull T2,@NonNull R> @NonNull Flowable<R>	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 a Flowable that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two other Publishers.
static <@NonNull T1,@NonNull T2,@NonNull R> @NonNull Flowable<R>	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 a Flowable that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two other Publishers.
static <@NonNull T1,@NonNull T2,@NonNull R> @NonNull Maybe<R>	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 a Maybe that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two other MaybeSources.
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 an Observable that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two other ObservableSources.
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 an Observable that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two other ObservableSources.
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 an Observable that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two other ObservableSources.
static <@NonNull T1,@NonNull T2,@NonNull R> @NonNull Single<R>	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 a Single that emits the results of a specified combiner function applied to two items emitted by two other SingleSources.
<@NonNull U,@NonNull R> @NonNull Flowable<R>	Flowable.zipWith(@NonNull java.lang.Iterable<@NonNull U> other, @NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> zipper)	Returns a Flowable that emits items that are the result of applying a specified function to pairs of values, one each from the current Flowable and a specified Iterable sequence.
<@NonNull U,@NonNull R> @NonNull Flowable<R>	Flowable.zipWith(@NonNull org.reactivestreams.Publisher<? extends @NonNull U> other, @NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> zipper)	Returns a Flowable that emits items that are the result of applying a specified function to pairs of values, one each from the current Flowable and another specified Publisher.
<@NonNull U,@NonNull R> @NonNull Flowable<R>	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 a Flowable that emits items that are the result of applying a specified function to pairs of values, one each from the current Flowable and another specified Publisher.
<@NonNull U,@NonNull R> @NonNull Flowable<R>	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 a Flowable that emits items that are the result of applying a specified function to pairs of values, one each from the current Flowable and another specified Publisher.
<@NonNull U,@NonNull R> @NonNull Maybe<R>	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 other MaybeSource signal a success value then applies the given BiFunction to those values and emits the BiFunction's resulting value to downstream.
<@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 an Observable that emits items that are the result of applying a specified function to pairs of values, one each from the current Observable and another specified ObservableSource.
<@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 an Observable that emits items that are the result of applying a specified function to pairs of values, one each from the current Observable and another specified ObservableSource.
<@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 an Observable that emits items that are the result of applying a specified function to pairs of values, one each from the current Observable and another specified ObservableSource.
<@NonNull U,@NonNull R> @NonNull Observable<R>	Observable.zipWith(@NonNull java.lang.Iterable<@NonNull U> other, @NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> zipper)	Returns an Observable that emits items that are the result of applying a specified function to pairs of values, one each from the current Observable and a specified Iterable sequence.
<@NonNull U,@NonNull R> @NonNull Single<R>	Single.zipWith(@NonNull SingleSource<@NonNull U> other, @NonNull BiFunction<? super @NonNull T,? super @NonNull U,? extends @NonNull R> zipper)	Returns a Single that emits the result of applying a specified function to the pair of items emitted by the current Single and another specified SingleSource.

Uses of BiFunction in io.reactivex.rxjava3.internal.functions

Fields in io.reactivex.rxjava3.internal.functions declared as BiFunction

Modifier and Type	Field	Description
(package private) BiFunction<? super T1,? super T2,? extends R>	Functions.Array2Func.f

Methods in io.reactivex.rxjava3.internal.functions with parameters of type BiFunction

Modifier and Type	Method	Description
static <T1,T2,R> @NonNull Function<java.lang.Object[],R>	Functions.toFunction(@NonNull BiFunction<? super T1,? super T2,? extends R> f)

Constructors in io.reactivex.rxjava3.internal.functions with parameters of type BiFunction

Constructor	Description
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 BiFunction

Modifier and Type	Field	Description
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>	ParallelMapTryOptional.errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>	ParallelMapTryOptional.ParallelMapTryConditionalSubscriber.errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>	ParallelMapTryOptional.ParallelMapTrySubscriber.errorHandler

Constructors in io.reactivex.rxjava3.internal.jdk8 with parameters of type BiFunction

Constructor	Description
ParallelMapTryConditionalSubscriber(ConditionalSubscriber<? super R> actual, Function<? super T,java.util.Optional<? extends R>> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelMapTryOptional(ParallelFlowable<T> source, Function<? super T,java.util.Optional<? extends R>> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelMapTrySubscriber(org.reactivestreams.Subscriber<? super R> actual, Function<? super T,java.util.Optional<? extends R>> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)

Uses of BiFunction in io.reactivex.rxjava3.internal.operators.flowable

Classes in io.reactivex.rxjava3.internal.operators.flowable that implement BiFunction

Modifier and Type	Class	Description
(package private) static class	FlowableInternalHelper.SimpleBiGenerator<T,S>
(package private) static class	FlowableInternalHelper.SimpleGenerator<T,S>

Fields in io.reactivex.rxjava3.internal.operators.flowable declared as BiFunction

Modifier and Type	Field	Description
(package private) BiFunction<T,T,T>	FlowableScan.accumulator
(package private) BiFunction<T,T,T>	FlowableScan.ScanSubscriber.accumulator
(package private) BiFunction<R,? super T,R>	FlowableScanSeed.accumulator
(package private) BiFunction<R,? super T,R>	FlowableScanSeed.ScanSeedSubscriber.accumulator
private BiFunction<? super T,? super U,? extends R>	FlowableInternalHelper.FlatMapWithCombinerInner.combiner
private BiFunction<? super T,? super U,? extends R>	FlowableInternalHelper.FlatMapWithCombinerOuter.combiner
(package private) BiFunction<? super T,? super U,? extends R>	FlowableWithLatestFrom.combiner
(package private) BiFunction<? super T,? super U,? extends R>	FlowableWithLatestFrom.WithLatestFromSubscriber.combiner
(package private) BiFunction<S,Emitter<T>,S>	FlowableGenerate.generator
(package private) BiFunction<S,? super Emitter<T>,S>	FlowableGenerate.GeneratorSubscription.generator
(package private) BiFunction<T,T,T>	FlowableOnBackpressureReduce.BackpressureReduceSubscriber.reducer
(package private) BiFunction<T,T,T>	FlowableOnBackpressureReduce.reducer
(package private) BiFunction<R,? super T,R>	FlowableOnBackpressureReduceWith.BackpressureReduceWithSubscriber.reducer
(package private) BiFunction<R,? super T,R>	FlowableOnBackpressureReduceWith.reducer
(package private) BiFunction<T,T,T>	FlowableReduce.reducer
(package private) BiFunction<T,T,T>	FlowableReduce.ReduceSubscriber.reducer
(package private) BiFunction<T,T,T>	FlowableReduceMaybe.reducer
(package private) BiFunction<T,T,T>	FlowableReduceMaybe.ReduceSubscriber.reducer
(package private) BiFunction<R,? super T,R>	FlowableReduceSeedSingle.reducer
(package private) BiFunction<R,? super T,R>	FlowableReduceSeedSingle.ReduceSeedObserver.reducer
(package private) BiFunction<R,? super T,R>	FlowableReduceWithSingle.reducer
(package private) BiFunction<? super TLeft,? super Flowable<TRight>,? extends R>	FlowableGroupJoin.GroupJoinSubscription.resultSelector
(package private) BiFunction<? super TLeft,? super Flowable<TRight>,? extends R>	FlowableGroupJoin.resultSelector
(package private) BiFunction<? super TLeft,? super TRight,? extends R>	FlowableJoin.JoinSubscription.resultSelector
(package private) BiFunction<? super TLeft,? super TRight,? extends R>	FlowableJoin.resultSelector
(package private) BiFunction<? super T,? super U,? extends V>	FlowableZipIterable.ZipIterableSubscriber.zipper
(package private) BiFunction<? super T,? super U,? extends V>	FlowableZipIterable.zipper

Methods in io.reactivex.rxjava3.internal.operators.flowable that return BiFunction

Modifier and Type	Method	Description
static <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 BiFunction

Modifier and Type	Method	Description
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)

Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type BiFunction

Constructor	Description
BackpressureReduceSubscriber(@NonNull org.reactivestreams.Subscriber<? super T> downstream, @NonNull BiFunction<T,T,T> reducer)
BackpressureReduceWithSubscriber(@NonNull org.reactivestreams.Subscriber<? super R> downstream, @NonNull Supplier<R> supplier, @NonNull BiFunction<R,? super T,R> reducer)
FlatMapWithCombinerInner(BiFunction<? super T,? super U,? extends R> combiner, T t)
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, java.lang.Iterable<U> other, BiFunction<? super T,? super U,? extends V> zipper)
GeneratorSubscription(org.reactivestreams.Subscriber<? super T> actual, BiFunction<S,? super Emitter<T>,S> generator, Consumer<? super S> disposeState, S initialState)
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)
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)
ReduceSeedObserver(SingleObserver<? super R> actual, BiFunction<R,? super T,R> reducer, R value)
ReduceSubscriber(org.reactivestreams.Subscriber<? super T> actual, BiFunction<T,T,T> reducer)
ReduceSubscriber(MaybeObserver<? super T> actual, BiFunction<T,T,T> reducer)
ScanSeedSubscriber(org.reactivestreams.Subscriber<? super R> actual, BiFunction<R,? super T,R> accumulator, R value, int prefetch)
ScanSubscriber(org.reactivestreams.Subscriber<? super T> actual, BiFunction<T,T,T> accumulator)
WithLatestFromSubscriber(org.reactivestreams.Subscriber<? super R> actual, BiFunction<? super T,? super U,? extends R> combiner)
ZipIterableSubscriber(org.reactivestreams.Subscriber<? super V> actual, java.util.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 BiFunction

Modifier and Type	Field	Description
(package private) BiFunction<? super T,? super U,? extends R>	MaybeFlatMapBiSelector.FlatMapBiMainObserver.InnerObserver.resultSelector
(package private) BiFunction<? super T,? super U,? extends R>	MaybeFlatMapBiSelector.resultSelector

Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type BiFunction

Constructor	Description
FlatMapBiMainObserver(MaybeObserver<? super R> actual, Function<? super T,? extends MaybeSource<? extends U>> mapper, BiFunction<? super T,? super U,? extends R> resultSelector)
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 BiFunction

Modifier and Type	Class	Description
(package private) static class	ObservableInternalHelper.SimpleBiGenerator<T,S>
(package private) static class	ObservableInternalHelper.SimpleGenerator<T,S>

Fields in io.reactivex.rxjava3.internal.operators.observable declared as BiFunction

Modifier and Type	Field	Description
(package private) BiFunction<T,T,T>	ObservableScan.accumulator
(package private) BiFunction<T,T,T>	ObservableScan.ScanObserver.accumulator
(package private) BiFunction<R,? super T,R>	ObservableScanSeed.accumulator
(package private) BiFunction<R,? super T,R>	ObservableScanSeed.ScanSeedObserver.accumulator
private BiFunction<? super T,? super U,? extends R>	ObservableInternalHelper.FlatMapWithCombinerInner.combiner
private BiFunction<? super T,? super U,? extends R>	ObservableInternalHelper.FlatMapWithCombinerOuter.combiner
(package private) BiFunction<? super T,? super U,? extends R>	ObservableWithLatestFrom.combiner
(package private) BiFunction<? super T,? super U,? extends R>	ObservableWithLatestFrom.WithLatestFromObserver.combiner
(package private) BiFunction<S,Emitter<T>,S>	ObservableGenerate.generator
(package private) BiFunction<S,? super Emitter<T>,S>	ObservableGenerate.GeneratorDisposable.generator
(package private) BiFunction<T,T,T>	ObservableReduceMaybe.ReduceObserver.reducer
(package private) BiFunction<T,T,T>	ObservableReduceMaybe.reducer
(package private) BiFunction<R,? super T,R>	ObservableReduceSeedSingle.reducer
(package private) BiFunction<R,? super T,R>	ObservableReduceSeedSingle.ReduceSeedObserver.reducer
(package private) BiFunction<R,? super T,R>	ObservableReduceWithSingle.reducer
(package private) BiFunction<? super TLeft,? super Observable<TRight>,? extends R>	ObservableGroupJoin.GroupJoinDisposable.resultSelector
(package private) BiFunction<? super TLeft,? super Observable<TRight>,? extends R>	ObservableGroupJoin.resultSelector
(package private) BiFunction<? super TLeft,? super TRight,? extends R>	ObservableJoin.JoinDisposable.resultSelector
(package private) BiFunction<? super TLeft,? super TRight,? extends R>	ObservableJoin.resultSelector
(package private) BiFunction<? super T,? super U,? extends V>	ObservableZipIterable.ZipIterableObserver.zipper
(package private) BiFunction<? super T,? super U,? extends V>	ObservableZipIterable.zipper

Methods in io.reactivex.rxjava3.internal.operators.observable that return BiFunction

Modifier and Type	Method	Description
static <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 BiFunction

Modifier and Type	Method	Description
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)

Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type BiFunction

Constructor	Description
FlatMapWithCombinerInner(BiFunction<? super T,? super U,? extends R> combiner, T t)
FlatMapWithCombinerOuter(BiFunction<? super T,? super U,? extends R> combiner, Function<? super T,? extends ObservableSource<? extends U>> mapper)
GeneratorDisposable(Observer<? super T> actual, BiFunction<S,? super Emitter<T>,S> generator, Consumer<? super S> disposeState, S initialState)
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)
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, java.lang.Iterable<U> other, BiFunction<? super T,? super U,? extends V> zipper)
ReduceObserver(MaybeObserver<? super T> observer, BiFunction<T,T,T> reducer)
ReduceSeedObserver(SingleObserver<? super R> actual, BiFunction<R,? super T,R> reducer, R value)
ScanObserver(Observer<? super T> actual, BiFunction<T,T,T> accumulator)
ScanSeedObserver(Observer<? super R> actual, BiFunction<R,? super T,R> accumulator, R value)
WithLatestFromObserver(Observer<? super R> actual, BiFunction<? super T,? super U,? extends R> combiner)
ZipIterableObserver(Observer<? super V> actual, java.util.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 BiFunction

Modifier and Type	Field	Description
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>	ParallelDoOnNextTry.errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>	ParallelDoOnNextTry.ParallelDoOnNextConditionalSubscriber.errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>	ParallelDoOnNextTry.ParallelDoOnNextSubscriber.errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>	ParallelFilterTry.BaseFilterSubscriber.errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>	ParallelFilterTry.errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>	ParallelMapTry.errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>	ParallelMapTry.ParallelMapTryConditionalSubscriber.errorHandler
(package private) BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling>	ParallelMapTry.ParallelMapTrySubscriber.errorHandler
(package private) BiFunction<R,? super T,R>	ParallelReduce.ParallelReduceSubscriber.reducer
(package private) BiFunction<R,? super T,R>	ParallelReduce.reducer
(package private) BiFunction<T,T,T>	ParallelReduceFull.ParallelReduceFullInnerSubscriber.reducer
(package private) BiFunction<T,T,T>	ParallelReduceFull.ParallelReduceFullMainSubscriber.reducer
(package private) BiFunction<T,T,T>	ParallelReduceFull.reducer

Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type BiFunction

Constructor	Description
BaseFilterSubscriber(Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelDoOnNextConditionalSubscriber(ConditionalSubscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelDoOnNextSubscriber(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelDoOnNextTry(ParallelFlowable<T> source, Consumer<? super T> onNext, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFilterConditionalSubscriber(ConditionalSubscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFilterSubscriber(org.reactivestreams.Subscriber<? super T> actual, Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelFilterTry(ParallelFlowable<T> source, Predicate<? super T> predicate, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelMapTry(ParallelFlowable<T> source, Function<? super T,? extends R> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelMapTryConditionalSubscriber(ConditionalSubscriber<? super R> actual, Function<? super T,? extends R> mapper, BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)
ParallelMapTrySubscriber(org.reactivestreams.Subscriber<? super R> actual, Function<? super T,? extends R> mapper, BiFunction<? super java.lang.Long,? super java.lang.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)
ParallelReduceFullInnerSubscriber(ParallelReduceFull.ParallelReduceFullMainSubscriber<T> parent, BiFunction<T,T,T> reducer)
ParallelReduceFullMainSubscriber(org.reactivestreams.Subscriber<? super T> subscriber, int n, BiFunction<T,T,T> reducer)
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 BiFunction

Modifier and Type	Field	Description
(package private) BiFunction<? super T,? super U,? extends R>	SingleFlatMapBiSelector.FlatMapBiMainObserver.InnerObserver.resultSelector
(package private) BiFunction<? super T,? super U,? extends R>	SingleFlatMapBiSelector.resultSelector

Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type BiFunction

Constructor	Description
FlatMapBiMainObserver(SingleObserver<? super R> actual, Function<? super T,? extends SingleSource<? extends U>> mapper, BiFunction<? super T,? super U,? extends R> resultSelector)
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 BiFunction

Modifier and Type	Class	Description
class	ListAddBiConsumer
class	MergerBiFunction<T>	A BiFunction that merges two Lists into a new list.

Methods in io.reactivex.rxjava3.internal.util that return BiFunction

Modifier and Type	Method	Description
static <T> BiFunction<java.util.List<T>,T,java.util.List<T>>	ListAddBiConsumer.instance()

Uses of BiFunction in io.reactivex.rxjava3.parallel

Classes in io.reactivex.rxjava3.parallel that implement BiFunction

Modifier and Type	Class	Description
class	ParallelFailureHandling	Enumerations for handling failure within a parallel operator.

Methods in io.reactivex.rxjava3.parallel with parameters of type BiFunction

Modifier and Type	Method	Description
@NonNull ParallelFlowable<T>	ParallelFlowable.doOnNext(@NonNull Consumer<? super @NonNull T> onNext, @NonNull BiFunction<? super java.lang.Long,? super java.lang.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.
@NonNull ParallelFlowable<T>	ParallelFlowable.filter(@NonNull Predicate<? super @NonNull T> predicate, @NonNull BiFunction<? super java.lang.Long,? super java.lang.Throwable,ParallelFailureHandling> errorHandler)	Filters the source values on each 'rail' and handles errors based on the returned value by the handler function.
<@NonNull R> @NonNull ParallelFlowable<R>	ParallelFlowable.map(@NonNull Function<? super @NonNull T,? extends @NonNull R> mapper, @NonNull BiFunction<? super java.lang.Long,? super java.lang.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.
<@NonNull R> @NonNull ParallelFlowable<R>	ParallelFlowable.mapOptional(@NonNull Function<? super @NonNull T,@NonNull java.util.Optional<? extends @NonNull R>> mapper, @NonNull BiFunction<? super java.lang.Long,? super java.lang.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.
@NonNull Flowable<T>	ParallelFlowable.reduce(@NonNull BiFunction<@NonNull T,@NonNull T,@NonNull T> reducer)	Reduces all values within a 'rail' and across 'rails' with a reducer function into one Flowable sequence.
<@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 an initialSupplier value.

Uses of BiFunction in io.reactivex.rxjava3.plugins

Fields in io.reactivex.rxjava3.plugins declared as BiFunction

Modifier and Type	Field	Description
(package private) static @Nullable BiFunction<? super Completable,? super CompletableObserver,? extends CompletableObserver>	RxJavaPlugins.onCompletableSubscribe
(package private) static @Nullable BiFunction<? super Flowable,? super org.reactivestreams.Subscriber,? extends org.reactivestreams.Subscriber>	RxJavaPlugins.onFlowableSubscribe
(package private) static @Nullable BiFunction<? super Maybe,? super MaybeObserver,? extends MaybeObserver>	RxJavaPlugins.onMaybeSubscribe
(package private) static @Nullable BiFunction<? super Observable,? super Observer,? extends Observer>	RxJavaPlugins.onObservableSubscribe
(package private) static @Nullable BiFunction<? super ParallelFlowable,? super org.reactivestreams.Subscriber[],? extends org.reactivestreams.Subscriber[]>	RxJavaPlugins.onParallelSubscribe
(package private) static @Nullable BiFunction<? super Single,? super SingleObserver,? extends SingleObserver>	RxJavaPlugins.onSingleSubscribe

Methods in io.reactivex.rxjava3.plugins that return BiFunction

Modifier and Type	Method	Description
static @Nullable BiFunction<? super Completable,? super CompletableObserver,? extends CompletableObserver>	RxJavaPlugins.getOnCompletableSubscribe()	Returns the current hook function.
static @Nullable BiFunction<? super Flowable,? super org.reactivestreams.Subscriber,? extends org.reactivestreams.Subscriber>	RxJavaPlugins.getOnFlowableSubscribe()	Returns the current hook function.
static @Nullable BiFunction<? super Maybe,? super MaybeObserver,? extends MaybeObserver>	RxJavaPlugins.getOnMaybeSubscribe()	Returns the current hook function.
static @Nullable BiFunction<? super Observable,? super Observer,? extends Observer>	RxJavaPlugins.getOnObservableSubscribe()	Returns the current hook function.
static @Nullable BiFunction<? super ParallelFlowable,? super org.reactivestreams.Subscriber[],? extends org.reactivestreams.Subscriber[]>	RxJavaPlugins.getOnParallelSubscribe()	Returns the current hook function.
static @Nullable BiFunction<? super Single,? super SingleObserver,? extends SingleObserver>	RxJavaPlugins.getOnSingleSubscribe()	Returns the current hook function.

Methods in io.reactivex.rxjava3.plugins with parameters of type BiFunction

Modifier and Type	Method	Description
(package private) static <@NonNull T,@NonNull U,@NonNull R> R	RxJavaPlugins.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,? super CompletableObserver,? extends CompletableObserver> onCompletableSubscribe)	Sets the specific hook function.
static void	RxJavaPlugins.setOnFlowableSubscribe(@Nullable BiFunction<? super Flowable,? super org.reactivestreams.Subscriber,? extends org.reactivestreams.Subscriber> onFlowableSubscribe)	Sets the specific hook function.
static void	RxJavaPlugins.setOnMaybeSubscribe(@Nullable BiFunction<? super Maybe,@NonNull MaybeObserver,? extends MaybeObserver> onMaybeSubscribe)	Sets the specific hook function.
static void	RxJavaPlugins.setOnObservableSubscribe(@Nullable BiFunction<? super Observable,? super Observer,? extends Observer> onObservableSubscribe)	Sets the specific hook function.
static void	RxJavaPlugins.setOnParallelSubscribe(@Nullable BiFunction<? super ParallelFlowable,? super org.reactivestreams.Subscriber[],? extends org.reactivestreams.Subscriber[]> handler)	Sets the specific hook function.
static void	RxJavaPlugins.setOnSingleSubscribe(@Nullable BiFunction<? super Single,? super SingleObserver,? extends SingleObserver> onSingleSubscribe)	Sets the specific hook function.