Uses of Interface
io.reactivex.rxjava3.functions.BiConsumer
Packages that use BiConsumer
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.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 BiConsumerModifier and TypeMethodDescriptionFlowable.collect
(@NonNull Supplier<? extends @NonNull U> initialItemSupplier, @NonNull BiConsumer<? super @NonNull U, ? super @NonNull T> collector) Collects items emitted by the finite sourcePublisher
into a single mutable data structure and returns aSingle
that emits this structure.Observable.collect
(@NonNull Supplier<? extends @NonNull U> initialItemSupplier, @NonNull BiConsumer<? super @NonNull U, ? super @NonNull T> collector) Collects items emitted by the finite sourceObservable
into a single mutable data structure and returns aSingle
that emits this structure.Flowable.collectInto
(@NonNull U initialItem, @NonNull BiConsumer<? super @NonNull U, ? super @NonNull T> collector) Collects items emitted by the finite sourcePublisher
into a single mutable data structure and returns aSingle
that emits this structure.Observable.collectInto
(@NonNull U initialItem, @NonNull BiConsumer<? super @NonNull U, ? super @NonNull T> collector) Collects items emitted by the finite sourceObservable
into a single mutable data structure and returns aSingle
that emits this structure.Maybe.doOnEvent
(@NonNull BiConsumer<@Nullable ? super @NonNull T, @Nullable ? super Throwable> onEvent) Calls the givenonEvent
callback with the (success value,null
) for anonSuccess
, (null
, throwable) for anonError
or (null
,null
) for anonComplete
signal from thisMaybe
before delivering said signal to the downstream.Single.doOnEvent
(@NonNull BiConsumer<@Nullable ? super @NonNull T, @Nullable ? super Throwable> onEvent) Calls the shared consumer with the error sent viaonError
or the value viaonSuccess
for eachSingleObserver
that subscribes to the currentSingle
.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.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 aSingle
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 BiConsumerModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
Methods in io.reactivex.rxjava3.internal.functions that return BiConsumerModifier and TypeMethodDescriptionstatic <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 BiConsumerModifier and TypeFieldDescription(package private) final BiConsumer
<? super T, ? super Throwable> BiConsumerSingleObserver.onCallback
Constructors in io.reactivex.rxjava3.internal.observers with parameters of type BiConsumerModifierConstructorDescriptionBiConsumerSingleObserver
(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 BiConsumerModifier and TypeFieldDescription(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 BiConsumerModifier and TypeMethodDescriptionstatic <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 BiConsumerModifierConstructorDescription(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 BiConsumerModifier and TypeFieldDescription(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 BiConsumerModifierConstructorDescription(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 BiConsumerModifier and TypeFieldDescription(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 BiConsumerModifier and TypeMethodDescriptionstatic <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 BiConsumerModifierConstructorDescription(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 BiConsumerModifier and TypeFieldDescription(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 BiConsumerModifierConstructorDescriptionParallelCollect
(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 BiConsumerModifier and TypeFieldDescription(package private) final BiConsumer
<? super T, ? super Throwable> SingleDoOnEvent.onEvent
Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type BiConsumerModifierConstructorDescriptionSingleDoOnEvent
(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 BiConsumerModifier and TypeMethodDescriptionfinal <@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 acollectionSupplier
and collected into with a collector action, emitting the collection at the end.