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
andCompletable
; 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 typeParallelFlowable
, a sub-DSL for working withFlowable
sequences in parallel.io.reactivex.rxjava3.plugins Contains the central plugin handlerRxJavaPlugins
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 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.<@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 aFlowable
that emits the results of a specified function to the pair of values emitted by the currentFlowable
and a specified collectionPublisher
.<@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 aFlowable
that emits the results of a specified function to the pair of values emitted by the currentFlowable
and a specified innerPublisher
.<@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 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.<@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 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.<@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 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.<@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 aMaybe
that emits the results of a specified function to the pair of values emitted by the currentMaybe
and a specified mappedMaybeSource
.<@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
.<@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
.<@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.<@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.<@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.<@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 aSingle
that emits the results of a specified function to the pair of values emitted by the currentSingle
and a specified mappedSingleSource
.<@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)
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
.<@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)
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
.<@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)
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
.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 aFlowable
that correlates twoPublisher
s 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 anObservable
that correlates twoObservableSource
s 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 twoPublisher
s 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 twoObservableSource
s 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 ofSubscription.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 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.<@NonNull R>
@NonNull Single<R>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.@NonNull Maybe<T>
Observable. reduce(@NonNull BiFunction<@NonNull T,@NonNull T,@NonNull T> reducer)
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.<@NonNull R>
@NonNull Single<R>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.<@NonNull R>
@NonNull Single<R>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.<@NonNull R>
@NonNull Single<R>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.@NonNull Flowable<T>
Flowable. scan(@NonNull BiFunction<@NonNull T,@NonNull T,@NonNull T> accumulator)
Returns aFlowable
that emits the first value emitted by the currentFlowable
, then emits one value for each subsequent value emitted by the currentFlowable
.<@NonNull R>
@NonNull Flowable<R>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
.@NonNull Observable<T>
Observable. scan(@NonNull BiFunction<@NonNull T,@NonNull T,@NonNull T> accumulator)
Returns anObservable
that emits the first value emitted by the currentObservable
, then emits one value for each subsequent value emitted by the currentObservable
.<@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
.<@NonNull R>
@NonNull Flowable<R>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
.<@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
.<@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 specifiedPublisher
into the currentFlowable
sequence by using theresultSelector
function only when the currentFlowable
(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 specifiedObservableSource
into the currentObservable
sequence by using theresultSelector
function only when the currentObservable
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 aFlowable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherPublisher
s.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 aFlowable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherPublisher
s.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 aFlowable
that emits the results of a specified combiner function applied to combinations of two items emitted, in sequence, by two otherPublisher
s.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 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.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 aSingle
that emits the results of a specified combiner function applied to two items emitted by two otherSingleSource
s.<@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 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.<@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 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
.<@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 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
.<@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 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
.<@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 otherMaybeSource
signal a success value then applies the givenBiFunction
to those values and emits theBiFunction
'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 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
.<@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
.<@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
.<@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 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.<@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 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 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 oneFlowable
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 aninitialSupplier
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>
RRxJavaPlugins. 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.
-