Uses of Interface
io.reactivex.rxjava3.functions.LongConsumer
-
Packages that use LongConsumer 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.operators.flowable io.reactivex.rxjava3.internal.operators.parallel io.reactivex.rxjava3.parallel Contains the base typeParallelFlowable
, a sub-DSL for working withFlowable
sequences in parallel. -
-
Uses of LongConsumer in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type LongConsumer Modifier and Type Method Description @NonNull Flowable<T>
Flowable. 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).@NonNull Flowable<T>
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 LongConsumer Modifier and Type Class Description (package private) static class
Functions.EmptyLongConsumer
Fields in io.reactivex.rxjava3.internal.functions declared as LongConsumer Modifier and Type Field Description static LongConsumer
Functions. EMPTY_LONG_CONSUMER
-
Uses of LongConsumer in io.reactivex.rxjava3.internal.operators.flowable
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as LongConsumer Modifier and Type Field Description private LongConsumer
FlowableDoOnLifecycle. onRequest
(package private) LongConsumer
FlowableDoOnLifecycle.SubscriptionLambdaSubscriber. onRequest
Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type LongConsumer Constructor Description FlowableDoOnLifecycle(Flowable<T> source, Consumer<? super org.reactivestreams.Subscription> onSubscribe, LongConsumer onRequest, Action onCancel)
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 LongConsumer Modifier and Type Field Description (package private) LongConsumer
ParallelPeek. onRequest
Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type LongConsumer Constructor Description ParallelPeek(ParallelFlowable<T> source, Consumer<? super T> onNext, Consumer<? super T> onAfterNext, Consumer<? super java.lang.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 LongConsumer Modifier and Type Method Description @NonNull ParallelFlowable<T>
ParallelFlowable. doOnRequest(@NonNull LongConsumer onRequest)
Call the specified consumer with the request amount if any rail receives a request.
-