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

Packages that use BiConsumer

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.observers
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.parallel	Contains the base type ParallelFlowable, a sub-DSL for working with Flowable sequences in parallel.

Uses of BiConsumer in io.reactivex.rxjava3.core

Methods in io.reactivex.rxjava3.core with parameters of type BiConsumer

Modifier and Type	Method	Description
<@NonNull U> @NonNull Single<U>	Flowable.collect(@NonNull Supplier<? extends @NonNull U> initialItemSupplier, @NonNull BiConsumer<? super @NonNull U,? super @NonNull T> collector)	Collects items emitted by the finite source Publisher into a single mutable data structure and returns a Single that emits this structure.
<@NonNull U> @NonNull Single<U>	Observable.collect(@NonNull Supplier<? extends @NonNull U> initialItemSupplier, @NonNull BiConsumer<? super @NonNull U,? super @NonNull T> collector)	Collects items emitted by the finite source Observable into a single mutable data structure and returns a Single that emits this structure.
<@NonNull U> @NonNull Single<U>	Flowable.collectInto(@NonNull U initialItem, @NonNull BiConsumer<? super @NonNull U,? super @NonNull T> collector)	Collects items emitted by the finite source Publisher into a single mutable data structure and returns a Single that emits this structure.
<@NonNull U> @NonNull Single<U>	Observable.collectInto(@NonNull U initialItem, @NonNull BiConsumer<? super @NonNull U,? super @NonNull T> collector)	Collects items emitted by the finite source Observable into a single mutable data structure and returns a Single that emits this structure.
@NonNull Maybe<T>	Maybe.doOnEvent(@NonNull BiConsumer<? super @NonNull T,? super java.lang.Throwable> onEvent)	Calls the given onEvent callback with the (success value, null) for an onSuccess, (null, throwable) for an onError or (null, null) for an onComplete signal from this Maybe before delivering said signal to the downstream.
@NonNull Single<T>	Single.doOnEvent(@NonNull BiConsumer<? super @NonNull T,? super java.lang.Throwable> onEvent)	Calls the shared consumer with the error sent via onError or the value via onSuccess for each SingleObserver that subscribes to the current Single.
static <@NonNull T,@NonNull S> @NonNull Flowable<T>	Flowable.generate(@NonNull Supplier<@NonNull S> initialState, @NonNull BiConsumer<@NonNull S,Emitter<@NonNull T>> 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 BiConsumer<@NonNull S,Emitter<@NonNull T>> 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 BiConsumer<@NonNull S,Emitter<@NonNull T>> 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 BiConsumer<@NonNull S,Emitter<@NonNull T>> generator, @NonNull Consumer<? super @NonNull S> disposeState)	Returns a cold, synchronous and stateful generator of values.
@NonNull Disposable	Single.subscribe(@NonNull BiConsumer<? super @NonNull T,? super java.lang.Throwable> onCallback)	Subscribes to a Single and provides a composite callback to handle the item it emits or any error notification it issues.

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

Classes in io.reactivex.rxjava3.internal.functions that implement BiConsumer

Modifier and Type	Class	Description
(package private) static class	Functions.ToMapKeySelector<K,T>
(package private) static class	Functions.ToMapKeyValueSelector<K,V,T>
(package private) static class	Functions.ToMultimapKeyValueSelector<K,V,T>

Methods in io.reactivex.rxjava3.internal.functions that return BiConsumer

Modifier and Type	Method	Description
static <T,K> BiConsumer<java.util.Map<K,T>,T>	Functions.toMapKeySelector(Function<? super T,? extends K> keySelector)
static <T,K,V> BiConsumer<java.util.Map<K,V>,T>	Functions.toMapKeyValueSelector(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector)
static <T,K,V> BiConsumer<java.util.Map<K,java.util.Collection<V>>,T>	Functions.toMultimapKeyValueSelector(Function<? super T,? extends K> keySelector, Function<? super T,? extends V> valueSelector, Function<? super K,? extends java.util.Collection<? super V>> collectionFactory)

Uses of BiConsumer in io.reactivex.rxjava3.internal.observers

Fields in io.reactivex.rxjava3.internal.observers declared as BiConsumer

Modifier and Type	Field	Description
(package private) BiConsumer<? super T,? super java.lang.Throwable>	BiConsumerSingleObserver.onCallback

Constructors in io.reactivex.rxjava3.internal.observers with parameters of type BiConsumer

Constructor	Description
BiConsumerSingleObserver(BiConsumer<? super T,? super java.lang.Throwable> onCallback)

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

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

Modifier and Type	Field	Description
(package private) BiConsumer<? super U,? super T>	FlowableCollect.collector
(package private) BiConsumer<? super U,? super T>	FlowableCollect.CollectSubscriber.collector
(package private) BiConsumer<? super U,? super T>	FlowableCollectSingle.collector
(package private) BiConsumer<? super U,? super T>	FlowableCollectSingle.CollectSubscriber.collector
(package private) BiConsumer<S,Emitter<T>>	FlowableInternalHelper.SimpleBiGenerator.consumer

Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type BiConsumer

Modifier and Type	Method	Description
static <T,S> BiFunction<S,Emitter<T>,S>	FlowableInternalHelper.simpleBiGenerator(BiConsumer<S,Emitter<T>> consumer)

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

Constructor	Description
CollectSubscriber(org.reactivestreams.Subscriber<? super U> actual, U u, BiConsumer<? super U,? super T> collector)
CollectSubscriber(SingleObserver<? super U> actual, U u, BiConsumer<? super U,? super T> collector)
FlowableCollect(Flowable<T> source, Supplier<? extends U> initialSupplier, BiConsumer<? super U,? super T> collector)
FlowableCollectSingle(Flowable<T> source, Supplier<? extends U> initialSupplier, BiConsumer<? super U,? super T> collector)
SimpleBiGenerator(BiConsumer<S,Emitter<T>> consumer)

Uses of BiConsumer in io.reactivex.rxjava3.internal.operators.maybe

Fields in io.reactivex.rxjava3.internal.operators.maybe declared as BiConsumer

Modifier and Type	Field	Description
(package private) BiConsumer<? super T,? super java.lang.Throwable>	MaybeDoOnEvent.DoOnEventMaybeObserver.onEvent
(package private) BiConsumer<? super T,? super java.lang.Throwable>	MaybeDoOnEvent.onEvent

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

Constructor	Description
DoOnEventMaybeObserver(MaybeObserver<? super T> actual, BiConsumer<? super T,? super java.lang.Throwable> onEvent)
MaybeDoOnEvent(MaybeSource<T> source, BiConsumer<? super T,? super java.lang.Throwable> onEvent)

Uses of BiConsumer in io.reactivex.rxjava3.internal.operators.observable

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

Modifier and Type	Field	Description
(package private) BiConsumer<? super U,? super T>	ObservableCollect.CollectObserver.collector
(package private) BiConsumer<? super U,? super T>	ObservableCollect.collector
(package private) BiConsumer<? super U,? super T>	ObservableCollectSingle.CollectObserver.collector
(package private) BiConsumer<? super U,? super T>	ObservableCollectSingle.collector
(package private) BiConsumer<S,Emitter<T>>	ObservableInternalHelper.SimpleBiGenerator.consumer

Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type BiConsumer

Modifier and Type	Method	Description
static <T,S> BiFunction<S,Emitter<T>,S>	ObservableInternalHelper.simpleBiGenerator(BiConsumer<S,Emitter<T>> consumer)

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

Constructor	Description
CollectObserver(Observer<? super U> actual, U u, BiConsumer<? super U,? super T> collector)
CollectObserver(SingleObserver<? super U> actual, U u, BiConsumer<? super U,? super T> collector)
ObservableCollect(ObservableSource<T> source, Supplier<? extends U> initialSupplier, BiConsumer<? super U,? super T> collector)
ObservableCollectSingle(ObservableSource<T> source, Supplier<? extends U> initialSupplier, BiConsumer<? super U,? super T> collector)
SimpleBiGenerator(BiConsumer<S,Emitter<T>> consumer)

Uses of BiConsumer in io.reactivex.rxjava3.internal.operators.parallel

Fields in io.reactivex.rxjava3.internal.operators.parallel declared as BiConsumer

Modifier and Type	Field	Description
(package private) BiConsumer<? super C,? super T>	ParallelCollect.collector
(package private) BiConsumer<? super C,? super T>	ParallelCollect.ParallelCollectSubscriber.collector

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

Constructor	Description
ParallelCollect(ParallelFlowable<? extends T> source, Supplier<? extends C> initialCollection, BiConsumer<? super C,? super T> collector)
ParallelCollectSubscriber(org.reactivestreams.Subscriber<? super C> subscriber, C initialValue, BiConsumer<? super C,? super T> collector)

Uses of BiConsumer in io.reactivex.rxjava3.internal.operators.single

Fields in io.reactivex.rxjava3.internal.operators.single declared as BiConsumer

Modifier and Type	Field	Description
(package private) BiConsumer<? super T,? super java.lang.Throwable>	SingleDoOnEvent.onEvent

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

Constructor	Description
SingleDoOnEvent(SingleSource<T> source, BiConsumer<? super T,? super java.lang.Throwable> onEvent)

Uses of BiConsumer in io.reactivex.rxjava3.parallel

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

Modifier and Type	Method	Description
<@NonNull C> @NonNull ParallelFlowable<C>	ParallelFlowable.collect(@NonNull Supplier<? extends @NonNull C> collectionSupplier, @NonNull BiConsumer<? super @NonNull C,? super @NonNull T> collector)	Collect the elements in each rail into a collection supplied via a collectionSupplier and collected into with a collector action, emitting the collection at the end.