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 and Completable; 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 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 LongConsumer

Modifier and Type	Method	Description
final @NonNull Flowable<T>	Flowable.doOnLifecycle(@NonNull Consumer<? super org.reactivestreams.Subscription> onSubscribe, @NonNull LongConsumer onRequest, @NonNull Action onCancel)	Calls the appropriate onXXX method (shared between all Subscribers) for the lifecycle events of the sequence (subscription, cancellation, requesting).
final @NonNull Flowable<T>	Flowable.doOnRequest(@NonNull LongConsumer onRequest)	Calls the given LongConsumer with the request amount from the downstream before forwarding it to the current Flowable.

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 final class	Functions.EmptyLongConsumer

Fields in io.reactivex.rxjava3.internal.functions declared as LongConsumer

Modifier and Type	Field	Description
static final 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 final LongConsumer	FlowableDoOnLifecycle.onRequest
(package private) final LongConsumer	FlowableDoOnLifecycle.SubscriptionLambdaSubscriber.onRequest

Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type LongConsumer

Modifier	Constructor	Description
	FlowableDoOnLifecycle(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 LongConsumer

Modifier and Type	Field	Description
(package private) final LongConsumer	ParallelPeek.onRequest

Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type LongConsumer

Modifier	Constructor	Description
	ParallelPeek(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 LongConsumer

Modifier and Type	Method	Description
final @NonNull ParallelFlowable<T>	ParallelFlowable.doOnRequest(@NonNull LongConsumer onRequest)	Call the specified consumer with the request amount if any rail receives a request.