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
andCompletable
; 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 typeParallelFlowable
, a sub-DSL for working withFlowable
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 sourcePublisher
into a single mutable data structure and returns aSingle
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 sourceObservable
into a single mutable data structure and returns aSingle
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 sourcePublisher
into a single mutable data structure and returns aSingle
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 sourceObservable
into a single mutable data structure and returns aSingle
that emits this structure.@NonNull Maybe<T>
Maybe. doOnEvent(@NonNull BiConsumer<? super @NonNull T,? super java.lang.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.@NonNull Single<T>
Single. doOnEvent(@NonNull BiConsumer<? super @NonNull T,? super java.lang.Throwable> onEvent)
Calls the shared consumer with the error sent viaonError
or the value viaonSuccess
for eachSingleObserver
that subscribes to the currentSingle
.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 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 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 acollectionSupplier
and collected into with a collector action, emitting the collection at the end.
-