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
final <@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.
final <@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.
final <@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.
final <@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.
final @NonNull Maybe<T>	Maybe.doOnEvent(@NonNull BiConsumer<@Nullable ? super @NonNull T, @Nullable ? super 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.
final @NonNull Single<T>	Single.doOnEvent(@NonNull BiConsumer<@Nullable ? super @NonNull T, @Nullable ? super 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.
final @NonNull Disposable	Single.subscribe(@NonNull BiConsumer<@Nullable ? super @NonNull T, @Nullable ? super 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

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

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

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

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

Modifier	Constructor	Description
	BiConsumerSingleObserver(BiConsumer<? super T, ? super Throwable> onCallback)

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

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

Modifier	Constructor	Description
	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)

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

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

Modifier	Constructor	Description
	MaybeDoOnEvent(MaybeSource<T> source, BiConsumer<? super T, ? super Throwable> onEvent)

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

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

Modifier	Constructor	Description
	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)

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

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

Modifier	Constructor	Description
	ParallelCollect(ParallelFlowable<? extends T> source, Supplier<? extends C> initialCollection, BiConsumer<? super C, ? super T> collector)

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

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

Modifier	Constructor	Description
	SingleDoOnEvent(SingleSource<T> source, BiConsumer<? super T, ? super 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
final <@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.