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

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

Modifier and Type	Class	Description
(package private) static final class	Functions.ToMapKeySelector<K,T>
(package private) static final class	Functions.ToMapKeyValueSelector<K,V,T>
(package private) static final 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<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

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

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

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

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

Modifier and Type	Field	Description
(package private) final BiConsumer<? super U, ? super T>	FlowableCollect.collector
(package private) final BiConsumer<? super U, ? super T>	FlowableCollect.CollectSubscriber.collector
(package private) final BiConsumer<? super U, ? super T>	FlowableCollectSingle.collector
(package private) final BiConsumer<? super U, ? super T>	FlowableCollectSingle.CollectSubscriber.collector
(package private) final 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

Modifier	Constructor	Description
(package private)	CollectSubscriber(org.reactivestreams.Subscriber<? super U> actual, U u, BiConsumer<? super U, ? super T> collector)
(package private)	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)
(package private)	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) final BiConsumer<? super T, ? super Throwable>	MaybeDoOnEvent.DoOnEventMaybeObserver.onEvent
(package private) final BiConsumer<? super T, ? super Throwable>	MaybeDoOnEvent.onEvent

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

Modifier	Constructor	Description
(package private)	DoOnEventMaybeObserver(MaybeObserver<? super T> actual, BiConsumer<? super T, ? super Throwable> onEvent)
	MaybeDoOnEvent(MaybeSource<T> source, BiConsumer<? super T, ? super 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) final BiConsumer<? super U, ? super T>	ObservableCollect.CollectObserver.collector
(package private) final BiConsumer<? super U, ? super T>	ObservableCollect.collector
(package private) final BiConsumer<? super U, ? super T>	ObservableCollectSingle.CollectObserver.collector
(package private) final BiConsumer<? super U, ? super T>	ObservableCollectSingle.collector
(package private) final 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

Modifier	Constructor	Description
(package private)	CollectObserver(Observer<? super U> actual, U u, BiConsumer<? super U, ? super T> collector)
(package private)	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)
(package private)	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) final BiConsumer<? super C, ? super T>	ParallelCollect.collector
(package private) final BiConsumer<? super C, ? super T>	ParallelCollect.ParallelCollectSubscriber.collector

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)
(package private)	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) final BiConsumer<? super T, ? super Throwable>	SingleDoOnEvent.onEvent

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.