Uses of Interface
io.reactivex.rxjava3.functions.LongConsumer
Packages that use LongConsumer
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 LongConsumer in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type LongConsumerModifier and TypeMethodDescriptionFlowable.doOnLifecycle
(@NonNull Consumer<? super org.reactivestreams.Subscription> onSubscribe, @NonNull LongConsumer onRequest, @NonNull Action onCancel) Calls the appropriateonXXX
method (shared between allSubscriber
s) for the lifecycle events of the sequence (subscription, cancellation, requesting).Flowable.doOnRequest
(@NonNull LongConsumer onRequest) Calls the givenLongConsumer
with the request amount from the downstream before forwarding it to the currentFlowable
. -
Uses of LongConsumer in io.reactivex.rxjava3.internal.functions
Classes in io.reactivex.rxjava3.internal.functions that implement LongConsumerModifier and TypeClassDescription(package private) static final class
Fields in io.reactivex.rxjava3.internal.functions declared as LongConsumer -
Uses of LongConsumer in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as LongConsumerModifier and TypeFieldDescriptionprivate final LongConsumer
FlowableDoOnLifecycle.onRequest
(package private) final LongConsumer
FlowableDoOnLifecycle.SubscriptionLambdaSubscriber.onRequest
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type LongConsumerModifierConstructorDescriptionFlowableDoOnLifecycle
(Flowable<T> source, Consumer<? super org.reactivestreams.Subscription> onSubscribe, LongConsumer onRequest, Action onCancel) (package private)
SubscriptionLambdaSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super org.reactivestreams.Subscription> onSubscribe, LongConsumer onRequest, Action onCancel) -
Uses of LongConsumer in io.reactivex.rxjava3.internal.operators.parallel
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as LongConsumerConstructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type LongConsumerModifierConstructorDescriptionParallelPeek
(ParallelFlowable<T> source, Consumer<? super T> onNext, Consumer<? super T> onAfterNext, Consumer<? super Throwable> onError, Action onComplete, Action onAfterTerminated, Consumer<? super org.reactivestreams.Subscription> onSubscribe, LongConsumer onRequest, Action onCancel) -
Uses of LongConsumer in io.reactivex.rxjava3.parallel
Methods in io.reactivex.rxjava3.parallel with parameters of type LongConsumerModifier and TypeMethodDescriptionfinal @NonNull ParallelFlowable
<T> ParallelFlowable.doOnRequest
(@NonNull LongConsumer onRequest) Call the specified consumer with the request amount if any rail receives a request.