Uses of Interface
io.reactivex.rxjava3.functions.Consumer
Packages that use Consumer
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.Classes supporting the Flowable base reactive class:
ConnectableFlowable
and
GroupedFlowable
.Classes supporting the Observable base reactive class:
ConnectableObservable
and
GroupedObservable
.Contains the base type
ParallelFlowable
,
a sub-DSL for working with Flowable
sequences in parallel.Contains the central plugin handler
RxJavaPlugins
class to hook into the lifecycle of the base reactive types and schedulers.-
Uses of Consumer in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core with parameters of type ConsumerModifier and TypeMethodDescriptionfinal void
Flowable.blockingForEach
(@NonNull Consumer<? super @NonNull T> onNext) Consumes the currentFlowable
in a blocking fashion and invokes the givenConsumer
with each upstream item on the current thread until the upstream terminates.final void
Flowable.blockingForEach
(@NonNull Consumer<? super @NonNull T> onNext, int bufferSize) Consumes the currentFlowable
in a blocking fashion and invokes the givenConsumer
with each upstream item on the current thread until the upstream terminates.final void
Observable.blockingForEach
(@NonNull Consumer<? super @NonNull T> onNext) Consumes the currentObservable
in a blocking fashion and invokes the givenConsumer
with each upstream item on the current thread until the upstream terminates.final void
Observable.blockingForEach
(@NonNull Consumer<? super @NonNull T> onNext, int capacityHint) Consumes the currentObservable
in a blocking fashion and invokes the givenConsumer
with each upstream item on the current thread until the upstream terminates.final void
Completable.blockingSubscribe
(@NonNull Action onComplete, @NonNull Consumer<? super Throwable> onError) Subscribes to the currentCompletable
and calls the appropriate callback on the current thread when it terminates.final void
Flowable.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onNext) Subscribes to the source and calls the given callbacks on the current thread.final void
Flowable.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onNext, int bufferSize) Subscribes to the source and calls the given callbacks on the current thread.final void
Flowable.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError) Subscribes to the source and calls the given callbacks on the current thread.final void
Flowable.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, int bufferSize) Subscribes to the source and calls the given callbacks on the current thread.final void
Flowable.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to the source and calls the given callbacks on the current thread.final void
Flowable.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, int bufferSize) Subscribes to the source and calls the given callbacks on the current thread.final void
Maybe.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onSuccess) Subscribes to the currentMaybe
and calls givenonSuccess
callback on the current thread when it completes normally.final void
Maybe.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError) Subscribes to the currentMaybe
and calls the appropriate callback on the current thread when it terminates.final void
Maybe.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to the currentMaybe
and calls the appropriate callback on the current thread when it terminates.final void
Observable.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onNext) Subscribes to the source and calls the given callbacks on the current thread.final void
Observable.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError) Subscribes to the source and calls the given callbacks on the current thread.final void
Observable.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to the source and calls the given callbacks on the current thread.final void
Single.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onSuccess) Subscribes to the currentSingle
and calls givenonSuccess
callback on the current thread when it completes normally.final void
Single.blockingSubscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError) Subscribes to the currentSingle
and calls the appropriate callback on the current thread when it terminates.Flowable.debounce
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that mirrors the currentFlowable
, except that it drops items emitted by the currentFlowable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.final @NonNull Observable
<T> Observable.debounce
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that mirrors the currentObservable
, except that it drops items emitted by the currentObservable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.Flowable.doAfterNext
(@NonNull Consumer<? super @NonNull T> onAfterNext) Calls the specified consumer with the current item after this item has been emitted to the downstream.final @NonNull Observable
<T> Observable.doAfterNext
(@NonNull Consumer<? super @NonNull T> onAfterNext) Calls the specifiedConsumer
with the current item after this item has been emitted to the downstream.Maybe.doAfterSuccess
(@NonNull Consumer<? super @NonNull T> onAfterSuccess) Calls the specifiedConsumer
with the success item after this item has been emitted to the downstream.Single.doAfterSuccess
(@NonNull Consumer<? super @NonNull T> onAfterSuccess) Calls the specified consumer with the success item after this item has been emitted to the downstream.Flowable.doOnEach
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, Action onComplete, Action onAfterTerminate) Calls the appropriate onXXX consumer (shared between all subscribers) whenever a signal with the same type passes through, before forwarding them to downstream.Invokes aConsumer
with aNotification
instances matching the signals emitted by the currentFlowable
before they are forwarded to the downstream.final @NonNull Observable
<T> Returns anObservable
that invokes aConsumer
with the appropriateNotification
object when the currentObservable
signals an item or terminates.private @NonNull Observable
<T> Observable.doOnEach
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, @NonNull Action onAfterTerminate) Calls the appropriateonXXX
consumer (shared between allObserver
s) whenever a signal with the same type passes through, before forwarding them to the downstream.final @NonNull Completable
Calls the sharedConsumer
with the error sent viaonError
for eachMaybeObserver
that subscribes to the currentMaybe
.final @NonNull Observable
<T> Calls the shared consumer with the error sent viaonError
for eachSingleObserver
that subscribes to the currentSingle
.final @NonNull Completable
final @NonNull Completable
Completable.doOnLifecycle
(@NonNull Consumer<? super Disposable> onSubscribe, @NonNull Action onDispose) Calls the appropriateonXXX
method (shared between allCompletableObserver
s) for the lifecycle events of the sequence (subscription, disposal).private @NonNull Completable
Completable.doOnLifecycle
(Consumer<? super Disposable> onSubscribe, Consumer<? super Throwable> onError, Action onComplete, Action onTerminate, Action onAfterTerminate, Action onDispose) Returns aCompletable
instance that calls the various callbacks upon the specific lifecycle events.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).Maybe.doOnLifecycle
(@NonNull Consumer<? super Disposable> onSubscribe, @NonNull Action onDispose) Calls the appropriateonXXX
method (shared between allMaybeObserver
s) for the lifecycle events of the sequence (subscription, disposal).final @NonNull Observable
<T> Observable.doOnLifecycle
(@NonNull Consumer<? super Disposable> onSubscribe, @NonNull Action onDispose) Calls the appropriateonXXX
method (shared between allObserver
s) for the lifecycle events of the sequence (subscription, disposal).Single.doOnLifecycle
(@NonNull Consumer<? super Disposable> onSubscribe, @NonNull Action onDispose) Calls the appropriateonXXX
method (shared between allSingleObserver
s) for the lifecycle events of the sequence (subscription, disposal).Calls the givenConsumer
with the value emitted by the currentFlowable
before forwarding it to the downstream.final @NonNull Observable
<T> Calls the givenConsumer
with the value emitted by the currentObservable
before forwarding it to the downstream.final @NonNull Completable
Completable.doOnSubscribe
(@NonNull Consumer<? super Disposable> onSubscribe) Returns aCompletable
instance that calls the givenonSubscribe
callback with the disposable that the downstreamCompletableObserver
s receive upon subscription.Flowable.doOnSubscribe
(@NonNull Consumer<? super org.reactivestreams.Subscription> onSubscribe) Calls the givenConsumer
with theSubscription
provided by the currentFlowable
upon subscription from the downstream before forwarding it to the subscriber'sonSubscribe
method.Maybe.doOnSubscribe
(@NonNull Consumer<? super Disposable> onSubscribe) Calls the sharedConsumer
with theDisposable
sent through theonSubscribe
for eachMaybeObserver
that subscribes to the currentMaybe
.final @NonNull Observable
<T> Observable.doOnSubscribe
(@NonNull Consumer<? super Disposable> onSubscribe) Single.doOnSubscribe
(@NonNull Consumer<? super Disposable> onSubscribe) Calls the shared consumer with theDisposable
sent through theonSubscribe
for eachSingleObserver
that subscribes to the currentSingle
.Maybe.doOnSuccess
(@NonNull Consumer<? super @NonNull T> onSuccess) Calls the sharedConsumer
with the success value sent viaonSuccess
for eachMaybeObserver
that subscribes to the currentMaybe
.Single.doOnSuccess
(@NonNull Consumer<? super @NonNull T> onSuccess) Calls the shared consumer with the success value sent viaonSuccess
for eachSingleObserver
that subscribes to the currentSingle
.final @NonNull Disposable
Subscribes to the currentFlowable
and receives notifications for each element.final @NonNull Disposable
Subscribes to theObservableSource
and calls aConsumer
for each item of the currentObservable
on its emission thread.final @NonNull Disposable
Flowable.forEachWhile
(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError) Subscribes to the currentFlowable
and receives notifications for each element and error events until theonNext
Predicate returnsfalse
.final @NonNull Disposable
Flowable.forEachWhile
(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to the currentFlowable
and receives notifications for each element and the terminal events until theonNext
Predicate returnsfalse
.final @NonNull Disposable
Observable.forEachWhile
(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError) Subscribes to theObservableSource
and calls aPredicate
for each item or aConsumer
with the error of the currentObservable
, on their original emission threads, until the predicate returnsfalse
.final @NonNull Disposable
Observable.forEachWhile
(@NonNull Predicate<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to theObservableSource
and calls aPredicate
for each item, aConsumer
with the error or anAction
upon completion of the currentObservable
, on their original emission threads, until the predicate returnsfalse
.Returns a cold, synchronous, stateless 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.Flowable.generate
(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, @NonNull Emitter<@NonNull T>, @NonNull S> generator, @NonNull Consumer<? super @NonNull S> disposeState) Returns a cold, synchronous, stateful and backpressure-aware generator of values.static <@NonNull T>
@NonNull Observable<T> Returns a cold, synchronous and stateless 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.static <@NonNull T,
@NonNull S>
@NonNull Observable<T> Observable.generate
(@NonNull Supplier<@NonNull S> initialState, @NonNull BiFunction<@NonNull S, Emitter<@NonNull T>, @NonNull S> generator, @NonNull Consumer<? super @NonNull S> disposeState) Returns a cold, synchronous and stateful generator of values.Flowable.onBackpressureBuffer
(int capacity, boolean delayError, boolean unbounded, @NonNull Action onOverflow, @NonNull Consumer<? super @NonNull T> onDropped) Buffers an optionally unlimited number of items from the currentFlowable
and allows it to emit as fast it can while allowing the downstream to consume the items at its own place.Flowable.onBackpressureBuffer
(long capacity, @Nullable Action onOverflow, @NonNull BackpressureOverflowStrategy overflowStrategy, @NonNull Consumer<? super @NonNull T> onDropped) Buffers an optionally unlimited number of items from the currentFlowable
and allows it to emit as fast it can while allowing the downstream to consume the items at its own place.Flowable.onBackpressureDrop
(@NonNull Consumer<? super @NonNull T> onDrop) Drops items from the currentFlowable
if the downstream is not ready to receive new items (indicated by a lack ofSubscription.request(long)
calls from it) and calls the givenConsumer
with such dropped items.Flowable.onBackpressureLatest
(@NonNull Consumer<? super @NonNull T> onDropped) Drops all but the latest item emitted by the currentFlowable
if the downstream is not ready to receive new items (indicated by a lack ofSubscription.request(long)
calls from it) and emits this latest item when the downstream becomes ready.Flowable.sample
(long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that emits the most recently emitted item (if any) emitted by the currentFlowable
within periodic time intervals, where the intervals are defined on a particularScheduler
and optionally emit the very last upstream item when the upstream completes.final @NonNull Observable
<T> Observable.sample
(long period, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that emits the most recently emitted item (if any) emitted by the currentObservable
within periodic time intervals, where the intervals are defined on a particularScheduler
.final @NonNull Disposable
Subscribes to thisCompletable
and calls back either theonError
oronComplete
functions.final @NonNull Disposable
Completable.subscribe
(@NonNull Action onComplete, @NonNull Consumer<? super Throwable> onError, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposable
CompletableObserver
, adds it to the givenDisposableContainer
and ensures, that if the upstream terminates or this particularDisposable
is disposed, theCompletableObserver
is removed from the given composite.final @NonNull Disposable
Subscribes to the currentFlowable
and provides a callback to handle the items it emits.final @NonNull Disposable
Flowable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError) Subscribes to the currentFlowable
and provides callbacks to handle the items it emits and any error notification it issues.final @NonNull Disposable
Flowable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to the currentFlowable
and provides callbacks to handle the items it emits and any error or completion notification it issues.final @NonNull Disposable
Flowable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposable
Subscriber
, adds it to the givenDisposableContainer
and ensures, that if the upstream terminates or this particularDisposable
is disposed, theSubscriber
is removed from the given container.final @NonNull Disposable
Subscribes to aMaybe
and provides a callback to handle the items it emits.final @NonNull Disposable
Maybe.subscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError) Subscribes to aMaybe
and provides callbacks to handle the items it emits and any error notification it issues.final @NonNull Disposable
Maybe.subscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to aMaybe
and provides callbacks to handle the items it emits and any error or completion notification it issues.final @NonNull Disposable
Maybe.subscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposable
MaybeObserver
, adds it to the givenDisposableContainer
and ensures, that if the upstream terminates or this particularDisposable
is disposed, theMaybeObserver
is removed from the given composite.final @NonNull Disposable
Subscribes to the currentObservable
and provides a callback to handle the items it emits.final @NonNull Disposable
Observable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError) Subscribes to the currentObservable
and provides callbacks to handle the items it emits and any error notification it signals.final @NonNull Disposable
Observable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete) Subscribes to the currentObservable
and provides callbacks to handle the items it emits and any error or completion notification it signals.final @NonNull Disposable
Observable.subscribe
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull Consumer<? super Throwable> onError, @NonNull Action onComplete, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposable
Observer
, adds it to the givenDisposableContainer
and ensures, that if the upstream terminates or this particularDisposable
is disposed, theObserver
is removed from the given container.final @NonNull Disposable
Subscribes to aSingle
and provides a callback to handle the item it emits.final @NonNull Disposable
Single.subscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError) Subscribes to aSingle
and provides callbacks to handle the item it emits or any error notification it issues.final @NonNull Disposable
Single.subscribe
(@NonNull Consumer<? super @NonNull T> onSuccess, @NonNull Consumer<? super Throwable> onError, @NonNull DisposableContainer container) Wraps the given onXXX callbacks into aDisposable
SingleObserver
, adds it to the givenDisposableContainer
and ensures, that if the upstream terminates or this particularDisposable
is disposed, theSingleObserver
is removed from the given container.Flowable.throttleFirst
(long skipDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that emits only the first item emitted by the currentFlowable
during sequential time windows of a specified duration, where the windows are managed by a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleFirst
(long skipDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that emits only the first item emitted by the currentObservable
during sequential time windows of a specified duration, where the windows are managed by a specifiedScheduler
.Flowable.throttleLast
(long intervalDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that emits only the last item emitted by the currentFlowable
during sequential time windows of a specified duration, where the duration is governed by a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleLast
(long intervalDuration, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that emits only the last item emitted by the currentObservable
during sequential time windows of a specified duration, where the duration is governed by a specifiedScheduler
.Flowable.throttleLatest
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Throttles items from the upstreamFlowable
by first emitting the next item from upstream, then periodically emitting the latest item (if any) when the specified timeout elapses between them, invoking the consumer for any dropped item.final @NonNull Observable
<T> Observable.throttleLatest
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, boolean emitLast, @NonNull Consumer<? super @NonNull T> onDropped) Throttles items from the currentObservable
by first emitting the next item from upstream, then periodically emitting the latest item (if any) when the specified timeout elapses between them, invoking the consumer for any dropped item.Flowable.throttleWithTimeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns aFlowable
that mirrors the currentFlowable
, except that it drops items emitted by the currentFlowable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.final @NonNull Observable
<T> Observable.throttleWithTimeout
(long timeout, @NonNull TimeUnit unit, @NonNull Scheduler scheduler, @NonNull Consumer<? super @NonNull T> onDropped) Returns anObservable
that mirrors the currentObservable
, except that it drops items emitted by the currentObservable
that are followed by newer items before a timeout value expires on a specifiedScheduler
.static <@NonNull R>
@NonNull CompletableCompletable.using
(@NonNull Supplier<@NonNull R> resourceSupplier, @NonNull Function<? super @NonNull R, ? extends CompletableSource> sourceSupplier, @NonNull Consumer<? super @NonNull R> resourceCleanup) Returns aCompletable
instance which manages a resource along with a customCompletableSource
instance while the subscription is active.static <@NonNull R>
@NonNull CompletableCompletable.using
(@NonNull Supplier<@NonNull R> resourceSupplier, @NonNull Function<? super @NonNull R, ? extends CompletableSource> sourceSupplier, @NonNull Consumer<? super @NonNull R> resourceCleanup, boolean eager) Returns aCompletable
instance which manages a resource along with a customCompletableSource
instance while the subscription is active and performs eager or lazy resource disposition.Flowable.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup) Constructs aFlowable
that creates a dependent resource object, aPublisher
with that resource and calls the providedresourceDisposer
function if this inner source terminates or the downstream cancels the flow.Flowable.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, @NonNull ? extends org.reactivestreams.Publisher<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup, boolean eager) Constructs aFlowable
that creates a dependent resource object, aPublisher
with that resource and calls the providedresourceDisposer
function if this inner source terminates or the downstream disposes the flow; doing it before these end-states have been reached ifeager == true
, after otherwise.Maybe.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends MaybeSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup) Constructs aMaybe
that creates a dependent resource object which is disposed of when the generatedMaybeSource
terminates or the downstream calls dispose().Maybe.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends MaybeSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup, boolean eager) Constructs aMaybe
that creates a dependent resource object which is disposed first ({code eager == true}) when the generatedMaybeSource
terminates or the downstream disposes; or after ({code eager == false}).static <@NonNull T,
@NonNull D>
@NonNull Observable<T> Observable.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends ObservableSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup) Constructs anObservable
that creates a dependent resource object, anObservableSource
with that resource and calls the providedresourceDisposer
function if this inner source terminates or the downstream disposes the flow.static <@NonNull T,
@NonNull D>
@NonNull Observable<T> Observable.using
(@NonNull Supplier<? extends @NonNull D> resourceSupplier, @NonNull Function<? super @NonNull D, ? extends ObservableSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull D> resourceCleanup, boolean eager) Constructs anObservable
that creates a dependent resource object, anObservableSource
with that resource and calls the provideddisposer
function if this inner source terminates or the downstream disposes the flow; doing it before these end-states have been reached ifeager == true
, after otherwise.Single.using
(@NonNull Supplier<@NonNull U> resourceSupplier, @NonNull Function<? super @NonNull U, ? extends SingleSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull U> resourceCleanup) Allows using and disposing a resource while running aSingleSource
instance generated from that resource (similar to a try-with-resources).Single.using
(@NonNull Supplier<@NonNull U> resourceSupplier, @NonNull Function<? super @NonNull U, ? extends SingleSource<? extends @NonNull T>> sourceSupplier, @NonNull Consumer<? super @NonNull U> resourceCleanup, boolean eager) Allows using and disposing a resource while running aSingleSource
instance generated from that resource (similar to a try-with-resources). -
Uses of Consumer in io.reactivex.rxjava3.flowables
Methods in io.reactivex.rxjava3.flowables with parameters of type ConsumerModifier and TypeMethodDescriptionConnectableFlowable.autoConnect
(int numberOfSubscribers, @NonNull Consumer<? super Disposable> connection) Returns aFlowable
that automatically connects (at most once) to thisConnectableFlowable
when the specified number ofSubscriber
s subscribe to it and calls the specified callback with theDisposable
associated with the established connection.abstract void
ConnectableFlowable.connect
(@NonNull Consumer<? super Disposable> connection) Instructs theConnectableFlowable
to begin emitting the items from its underlyingFlowable
to itsSubscriber
s. -
Uses of Consumer in io.reactivex.rxjava3.internal.functions
Classes in io.reactivex.rxjava3.internal.functions that implement ConsumerModifier and TypeClassDescription(package private) static final class
static class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.functions declared as ConsumerModifier and TypeFieldDescriptionFunctions.EMPTY_CONSUMER
Functions.ERROR_CONSUMER
Functions.ON_ERROR_MISSING
Wraps the consumed Throwable into an OnErrorNotImplementedException and signals it to the plugin error handler.(package private) final Consumer
<? super Notification<T>> Functions.NotificationOnComplete.onNotification
(package private) final Consumer
<? super Notification<T>> Functions.NotificationOnError.onNotification
(package private) final Consumer
<? super Notification<T>> Functions.NotificationOnNext.onNotification
static final Consumer
<org.reactivestreams.Subscription> Functions.REQUEST_MAX
Methods in io.reactivex.rxjava3.internal.functions that return ConsumerModifier and TypeMethodDescriptionstatic <T> Consumer
<T> Functions.actionConsumer
(Action action) static <T> Consumer
<T> Functions.boundedConsumer
(int bufferSize) static <T> Consumer
<T> Functions.emptyConsumer()
Returns an empty consumer that does nothing.Functions.notificationOnError
(Consumer<? super Notification<T>> onNotification) static <T> Consumer
<T> Functions.notificationOnNext
(Consumer<? super Notification<T>> onNotification) Methods in io.reactivex.rxjava3.internal.functions with parameters of type ConsumerModifier and TypeMethodDescriptionstatic <T> Action
Functions.notificationOnComplete
(Consumer<? super Notification<T>> onNotification) Functions.notificationOnError
(Consumer<? super Notification<T>> onNotification) static <T> Consumer
<T> Functions.notificationOnNext
(Consumer<? super Notification<T>> onNotification) Constructors in io.reactivex.rxjava3.internal.functions with parameters of type ConsumerModifierConstructorDescription(package private)
NotificationOnComplete
(Consumer<? super Notification<T>> onNotification) (package private)
NotificationOnError
(Consumer<? super Notification<T>> onNotification) (package private)
NotificationOnNext
(Consumer<? super Notification<T>> onNotification) -
Uses of Consumer in io.reactivex.rxjava3.internal.observers
Fields in io.reactivex.rxjava3.internal.observers declared as ConsumerModifier and TypeFieldDescriptionAbstractDisposableAutoRelease.onError
CallbackCompletableObserver.onError
ConsumerSingleObserver.onError
ForEachWhileObserver.onError
LambdaObserver.onError
DisposableAutoReleaseObserver.onNext
LambdaObserver.onNext
(package private) final Consumer
<? super Disposable> DisposableLambdaObserver.onSubscribe
(package private) final Consumer
<? super Disposable> LambdaObserver.onSubscribe
ConsumerSingleObserver.onSuccess
DisposableAutoReleaseMultiObserver.onSuccess
Methods in io.reactivex.rxjava3.internal.observers with parameters of type ConsumerModifier and TypeMethodDescriptionvoid
BlockingMultiObserver.blockingConsume
(Consumer<? super T> onSuccess, Consumer<? super Throwable> onError, Action onComplete) Blocks until the source completes and calls the appropriate callback.Constructors in io.reactivex.rxjava3.internal.observers with parameters of type ConsumerModifierConstructorDescription(package private)
AbstractDisposableAutoRelease
(DisposableContainer composite, Consumer<? super Throwable> onError, Action onComplete) CallbackCompletableObserver
(Consumer<? super Throwable> onError, Action onComplete) ConsumerSingleObserver
(Consumer<? super T> onSuccess, Consumer<? super Throwable> onError) DisposableAutoReleaseMultiObserver
(DisposableContainer composite, Consumer<? super T> onSuccess, Consumer<? super Throwable> onError, Action onComplete) DisposableAutoReleaseObserver
(DisposableContainer composite, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) DisposableLambdaObserver
(Observer<? super T> actual, Consumer<? super Disposable> onSubscribe, Action onDispose) ForEachWhileObserver
(Predicate<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) LambdaObserver
(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe) -
Uses of Consumer in io.reactivex.rxjava3.internal.operators.completable
Fields in io.reactivex.rxjava3.internal.operators.completable declared as ConsumerModifier and TypeFieldDescriptionCompletableUsing.disposer
CompletableUsing.UsingObserver.disposer
CompletablePeek.onError
CompletableDoOnEvent.onEvent
(package private) final Consumer
<? super Disposable> CompletablePeek.onSubscribe
Constructors in io.reactivex.rxjava3.internal.operators.completable with parameters of type ConsumerModifierConstructorDescriptionCompletableDoOnEvent
(CompletableSource source, Consumer<? super Throwable> onEvent) CompletablePeek
(CompletableSource source, Consumer<? super Disposable> onSubscribe, Consumer<? super Throwable> onError, Action onComplete, Action onTerminate, Action onAfterTerminate, Action onDispose) CompletableUsing
(Supplier<R> resourceSupplier, Function<? super R, ? extends CompletableSource> completableFunction, Consumer<? super R> disposer, boolean eager) (package private)
UsingObserver
(CompletableObserver actual, R resource, Consumer<? super R> disposer, boolean eager) -
Uses of Consumer in io.reactivex.rxjava3.internal.operators.flowable
Classes in io.reactivex.rxjava3.internal.operators.flowable that implement ConsumerModifier and TypeClassDescription(package private) static final class
static enum
(package private) static final class
(package private) static final class
final class
(package private) static final class
(package private) final class
Fields in io.reactivex.rxjava3.internal.operators.flowable declared as ConsumerModifier and TypeFieldDescription(package private) final Consumer
<? super Disposable> FlowableAutoConnect.connection
FlowableInternalHelper.SimpleGenerator.consumer
FlowableUsing.disposer
FlowableUsing.UsingSubscriber.disposer
FlowableGenerate.disposeState
FlowableGenerate.GeneratorSubscription.disposeState
FlowableDoAfterNext.DoAfterConditionalSubscriber.onAfterNext
FlowableDoAfterNext.DoAfterSubscriber.onAfterNext
FlowableDoAfterNext.onAfterNext
FlowableOnBackpressureDrop.BackpressureDropSubscriber.onDrop
FlowableOnBackpressureDrop.onDrop
FlowableDebounceTimed.DebounceTimedSubscriber.onDropped
FlowableDebounceTimed.onDropped
FlowableOnBackpressureBuffer.BackpressureBufferSubscriber.onDropped
FlowableOnBackpressureBuffer.onDropped
FlowableOnBackpressureBufferStrategy.OnBackpressureBufferStrategySubscriber.onDropped
FlowableOnBackpressureBufferStrategy.onDropped
FlowableOnBackpressureLatest.BackpressureLatestSubscriber.onDropped
FlowableOnBackpressureLatest.onDropped
FlowableSampleTimed.onDropped
FlowableSampleTimed.SampleTimedSubscriber.onDropped
FlowableThrottleFirstTimed.DebounceTimedSubscriber.onDropped
FlowableThrottleFirstTimed.onDropped
FlowableThrottleLatest.onDropped
FlowableThrottleLatest.ThrottleLatestSubscriber.onDropped
FlowableDoOnEach.DoOnEachConditionalSubscriber.onError
FlowableDoOnEach.DoOnEachSubscriber.onError
FlowableDoOnEach.onError
FlowableDoOnEach.DoOnEachConditionalSubscriber.onNext
FlowableDoOnEach.DoOnEachSubscriber.onNext
FlowableDoOnEach.onNext
private final Consumer
<? super org.reactivestreams.Subscription> FlowableDoOnLifecycle.onSubscribe
(package private) final Consumer
<? super org.reactivestreams.Subscription> FlowableDoOnLifecycle.SubscriptionLambdaSubscriber.onSubscribe
Fields in io.reactivex.rxjava3.internal.operators.flowable with type parameters of type ConsumerMethods in io.reactivex.rxjava3.internal.operators.flowable that return ConsumerModifier and TypeMethodDescriptionFlowableInternalHelper.subscriberOnError
(org.reactivestreams.Subscriber<T> subscriber) static <T> Consumer
<T> FlowableInternalHelper.subscriberOnNext
(org.reactivestreams.Subscriber<T> subscriber) Methods in io.reactivex.rxjava3.internal.operators.flowable with parameters of type ConsumerModifier and TypeMethodDescriptionvoid
FlowablePublish.connect
(Consumer<? super Disposable> connection) void
FlowableReplay.connect
(Consumer<? super Disposable> connection) static <T,
S> BiFunction <S, Emitter<T>, S> FlowableInternalHelper.simpleGenerator
(Consumer<Emitter<T>> consumer) static <T> void
FlowableBlockingSubscribe.subscribe
(org.reactivestreams.Publisher<? extends T> o, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) Subscribes to the source and calls the given actions on the current thread.static <T> void
FlowableBlockingSubscribe.subscribe
(org.reactivestreams.Publisher<? extends T> o, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, int bufferSize) Subscribes to the source and calls the given actions on the current thread.Constructors in io.reactivex.rxjava3.internal.operators.flowable with parameters of type ConsumerModifierConstructorDescription(package private)
BackpressureBufferSubscriber
(org.reactivestreams.Subscriber<? super T> actual, int bufferSize, boolean unbounded, boolean delayError, Action onOverflow, Consumer<? super T> onDropped) (package private)
BackpressureDropSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super T> onDrop) (package private)
BackpressureLatestSubscriber
(org.reactivestreams.Subscriber<? super T> downstream, Consumer<? super T> onDropped) (package private)
DebounceTimedSubscriber
(org.reactivestreams.Subscriber<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped) (package private)
DebounceTimedSubscriber
(org.reactivestreams.Subscriber<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped) (package private)
DoAfterConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Consumer<? super T> onAfterNext) (package private)
DoAfterSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super T> onAfterNext) (package private)
DoOnEachConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Action onAfterTerminate) (package private)
DoOnEachSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Action onAfterTerminate) FlowableAutoConnect
(ConnectableFlowable<? extends T> source, int numberOfSubscribers, Consumer<? super Disposable> connection) FlowableDebounceTimed
(Flowable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) FlowableDoAfterNext
(Flowable<T> source, Consumer<? super T> onAfterNext) FlowableDoOnEach
(Flowable<T> source, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Action onAfterTerminate) FlowableDoOnLifecycle
(Flowable<T> source, Consumer<? super org.reactivestreams.Subscription> onSubscribe, LongConsumer onRequest, Action onCancel) FlowableGenerate
(Supplier<S> stateSupplier, BiFunction<S, Emitter<T>, S> generator, Consumer<? super S> disposeState) FlowableOnBackpressureBuffer
(Flowable<T> source, int bufferSize, boolean unbounded, boolean delayError, Action onOverflow, Consumer<? super T> onDropped) FlowableOnBackpressureBufferStrategy
(Flowable<T> source, long bufferSize, Action onOverflow, BackpressureOverflowStrategy strategy, Consumer<? super T> onDropped) FlowableOnBackpressureDrop
(Flowable<T> source, Consumer<? super T> onDrop) FlowableOnBackpressureLatest
(Flowable<T> source, Consumer<? super T> onDropped) FlowableSampleTimed
(Flowable<T> source, long period, TimeUnit unit, Scheduler scheduler, boolean emitLast, Consumer<? super T> onDropped) FlowableThrottleFirstTimed
(Flowable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) FlowableThrottleLatest
(Flowable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, boolean emitLast, Consumer<? super T> onDropped) FlowableUsing
(Supplier<? extends D> resourceSupplier, Function<? super D, ? extends org.reactivestreams.Publisher<? extends T>> sourceSupplier, Consumer<? super D> disposer, boolean eager) (package private)
GeneratorSubscription
(org.reactivestreams.Subscriber<? super T> actual, BiFunction<S, ? super Emitter<T>, S> generator, Consumer<? super S> disposeState, S initialState) (package private)
OnBackpressureBufferStrategySubscriber
(org.reactivestreams.Subscriber<? super T> actual, Action onOverflow, BackpressureOverflowStrategy strategy, long bufferSize, Consumer<? super T> onDropped) (package private)
SampleTimedEmitLast
(org.reactivestreams.Subscriber<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
SampleTimedNoLast
(org.reactivestreams.Subscriber<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
SampleTimedSubscriber
(org.reactivestreams.Subscriber<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
SimpleGenerator
(Consumer<Emitter<T>> consumer) (package private)
SubscriptionLambdaSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super org.reactivestreams.Subscription> onSubscribe, LongConsumer onRequest, Action onCancel) (package private)
ThrottleLatestSubscriber
(org.reactivestreams.Subscriber<? super T> downstream, long timeout, TimeUnit unit, Scheduler.Worker worker, boolean emitLast, Consumer<? super T> onDropped) (package private)
UsingSubscriber
(org.reactivestreams.Subscriber<? super T> actual, D resource, Consumer<? super D> disposer, boolean eager) -
Uses of Consumer in io.reactivex.rxjava3.internal.operators.maybe
Fields in io.reactivex.rxjava3.internal.operators.maybe declared as ConsumerModifier and TypeFieldDescriptionMaybeUsing.UsingObserver.disposer
MaybeDoAfterSuccess.DoAfterObserver.onAfterSuccess
MaybeDoAfterSuccess.onAfterSuccess
MaybeCallbackObserver.onError
MaybePeek.onErrorCall
(package private) final Consumer
<? super Disposable> MaybeDoOnLifecycle.MaybeLifecycleObserver.onSubscribe
(package private) final Consumer
<? super Disposable> MaybeDoOnLifecycle.onSubscribe
(package private) final Consumer
<? super Disposable> MaybePeek.onSubscribeCall
MaybeCallbackObserver.onSuccess
MaybePeek.onSuccessCall
MaybeUsing.resourceDisposer
Constructors in io.reactivex.rxjava3.internal.operators.maybe with parameters of type ConsumerModifierConstructorDescription(package private)
DoAfterObserver
(MaybeObserver<? super T> actual, Consumer<? super T> onAfterSuccess) MaybeCallbackObserver
(Consumer<? super T> onSuccess, Consumer<? super Throwable> onError, Action onComplete) MaybeDoAfterSuccess
(MaybeSource<T> source, Consumer<? super T> onAfterSuccess) MaybeDoOnLifecycle
(Maybe<T> upstream, Consumer<? super Disposable> onSubscribe, Action onDispose) (package private)
MaybeLifecycleObserver
(MaybeObserver<? super T> downstream, Consumer<? super Disposable> onSubscribe, Action onDispose) MaybePeek
(MaybeSource<T> source, Consumer<? super Disposable> onSubscribeCall, Consumer<? super T> onSuccessCall, Consumer<? super Throwable> onErrorCall, Action onCompleteCall, Action onAfterTerminate, Action onDispose) MaybeUsing
(Supplier<? extends D> resourceSupplier, Function<? super D, ? extends MaybeSource<? extends T>> sourceSupplier, Consumer<? super D> resourceDisposer, boolean eager) (package private)
UsingObserver
(MaybeObserver<? super T> actual, D resource, Consumer<? super D> disposer, boolean eager) -
Uses of Consumer in io.reactivex.rxjava3.internal.operators.observable
Classes in io.reactivex.rxjava3.internal.operators.observable that implement ConsumerModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) static final class
(package private) static final class
Fields in io.reactivex.rxjava3.internal.operators.observable declared as ConsumerModifier and TypeFieldDescription(package private) final Consumer
<? super Disposable> ObservableAutoConnect.connection
ObservableInternalHelper.SimpleGenerator.consumer
ObservableUsing.disposer
ObservableUsing.UsingObserver.disposer
ObservableGenerate.disposeState
ObservableGenerate.GeneratorDisposable.disposeState
ObservableDoAfterNext.DoAfterObserver.onAfterNext
ObservableDoAfterNext.onAfterNext
ObservableDebounceTimed.DebounceTimedObserver.onDropped
ObservableDebounceTimed.onDropped
ObservableSampleTimed.onDropped
ObservableSampleTimed.SampleTimedObserver.onDropped
ObservableThrottleFirstTimed.DebounceTimedObserver.onDropped
ObservableThrottleFirstTimed.onDropped
ObservableThrottleLatest.onDropped
ObservableThrottleLatest.ThrottleLatestObserver.onDropped
ObservableDoOnEach.DoOnEachObserver.onError
ObservableDoOnEach.onError
ObservableDoOnEach.DoOnEachObserver.onNext
ObservableDoOnEach.onNext
private final Consumer
<? super Disposable> ObservableDoOnLifecycle.onSubscribe
Methods in io.reactivex.rxjava3.internal.operators.observable that return ConsumerModifier and TypeMethodDescriptionObservableInternalHelper.observerOnError
(Observer<T> observer) static <T> Consumer
<T> ObservableInternalHelper.observerOnNext
(Observer<T> observer) Methods in io.reactivex.rxjava3.internal.operators.observable with parameters of type ConsumerModifier and TypeMethodDescriptionvoid
ObservablePublish.connect
(Consumer<? super Disposable> connection) void
ObservableReplay.connect
(Consumer<? super Disposable> connection) static <T,
S> BiFunction <S, Emitter<T>, S> ObservableInternalHelper.simpleGenerator
(Consumer<Emitter<T>> consumer) static <T> void
ObservableBlockingSubscribe.subscribe
(ObservableSource<? extends T> o, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) Subscribes to the source and calls the given actions on the current thread.Constructors in io.reactivex.rxjava3.internal.operators.observable with parameters of type ConsumerModifierConstructorDescription(package private)
DebounceTimedObserver
(Observer<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped) (package private)
DebounceTimedObserver
(Observer<? super T> actual, long timeout, TimeUnit unit, Scheduler.Worker worker, Consumer<? super T> onDropped) (package private)
DoAfterObserver
(Observer<? super T> actual, Consumer<? super T> onAfterNext) (package private)
DoOnEachObserver
(Observer<? super T> actual, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Action onAfterTerminate) (package private)
GeneratorDisposable
(Observer<? super T> actual, BiFunction<S, ? super Emitter<T>, S> generator, Consumer<? super S> disposeState, S initialState) ObservableAutoConnect
(ConnectableObservable<? extends T> source, int numberOfObservers, Consumer<? super Disposable> connection) ObservableDebounceTimed
(ObservableSource<T> source, long timeout, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) ObservableDoAfterNext
(ObservableSource<T> source, Consumer<? super T> onAfterNext) ObservableDoOnEach
(ObservableSource<T> source, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Action onAfterTerminate) ObservableDoOnLifecycle
(Observable<T> upstream, Consumer<? super Disposable> onSubscribe, Action onDispose) ObservableGenerate
(Supplier<S> stateSupplier, BiFunction<S, Emitter<T>, S> generator, Consumer<? super S> disposeState) ObservableSampleTimed
(ObservableSource<T> source, long period, TimeUnit unit, Scheduler scheduler, boolean emitLast, Consumer<? super T> onDropped) ObservableThrottleFirstTimed
(ObservableSource<T> source, long timeout, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) ObservableThrottleLatest
(Observable<T> source, long timeout, TimeUnit unit, Scheduler scheduler, boolean emitLast, Consumer<? super T> onDropped) ObservableUsing
(Supplier<? extends D> resourceSupplier, Function<? super D, ? extends ObservableSource<? extends T>> sourceSupplier, Consumer<? super D> disposer, boolean eager) (package private)
SampleTimedEmitLast
(Observer<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
SampleTimedNoLast
(Observer<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
SampleTimedObserver
(Observer<? super T> actual, long period, TimeUnit unit, Scheduler scheduler, Consumer<? super T> onDropped) (package private)
SimpleGenerator
(Consumer<Emitter<T>> consumer) (package private)
ThrottleLatestObserver
(Observer<? super T> downstream, long timeout, TimeUnit unit, Scheduler.Worker worker, boolean emitLast, Consumer<? super T> onDropped) (package private)
-
Uses of Consumer in io.reactivex.rxjava3.internal.operators.parallel
Fields in io.reactivex.rxjava3.internal.operators.parallel declared as ConsumerModifier and TypeFieldDescriptionParallelPeek.onAfterNext
ParallelPeek.onError
ParallelDoOnNextTry.onNext
ParallelDoOnNextTry.ParallelDoOnNextConditionalSubscriber.onNext
ParallelDoOnNextTry.ParallelDoOnNextSubscriber.onNext
ParallelPeek.onNext
(package private) final Consumer
<? super org.reactivestreams.Subscription> ParallelPeek.onSubscribe
Constructors in io.reactivex.rxjava3.internal.operators.parallel with parameters of type ConsumerModifierConstructorDescription(package private)
ParallelDoOnNextConditionalSubscriber
(ConditionalSubscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) (package private)
ParallelDoOnNextSubscriber
(org.reactivestreams.Subscriber<? super T> actual, Consumer<? super T> onNext, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) ParallelDoOnNextTry
(ParallelFlowable<T> source, Consumer<? super T> onNext, BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) 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 Consumer in io.reactivex.rxjava3.internal.operators.single
Fields in io.reactivex.rxjava3.internal.operators.single declared as ConsumerModifier and TypeFieldDescriptionSingleUsing.disposer
SingleUsing.UsingSingleObserver.disposer
SingleDoAfterSuccess.DoAfterObserver.onAfterSuccess
SingleDoAfterSuccess.onAfterSuccess
SingleDoOnError.onError
(package private) final Consumer
<? super Disposable> SingleDoOnLifecycle.onSubscribe
(package private) final Consumer
<? super Disposable> SingleDoOnLifecycle.SingleLifecycleObserver.onSubscribe
(package private) final Consumer
<? super Disposable> SingleDoOnSubscribe.DoOnSubscribeSingleObserver.onSubscribe
(package private) final Consumer
<? super Disposable> SingleDoOnSubscribe.onSubscribe
SingleDoOnSuccess.onSuccess
Constructors in io.reactivex.rxjava3.internal.operators.single with parameters of type ConsumerModifierConstructorDescription(package private)
DoAfterObserver
(SingleObserver<? super T> actual, Consumer<? super T> onAfterSuccess) (package private)
DoOnSubscribeSingleObserver
(SingleObserver<? super T> actual, Consumer<? super Disposable> onSubscribe) SingleDoAfterSuccess
(SingleSource<T> source, Consumer<? super T> onAfterSuccess) SingleDoOnError
(SingleSource<T> source, Consumer<? super Throwable> onError) SingleDoOnLifecycle
(Single<T> upstream, Consumer<? super Disposable> onSubscribe, Action onDispose) SingleDoOnSubscribe
(SingleSource<T> source, Consumer<? super Disposable> onSubscribe) SingleDoOnSuccess
(SingleSource<T> source, Consumer<? super T> onSuccess) (package private)
SingleLifecycleObserver
(SingleObserver<? super T> downstream, Consumer<? super Disposable> onSubscribe, Action onDispose) SingleUsing
(Supplier<U> resourceSupplier, Function<? super U, ? extends SingleSource<? extends T>> singleFunction, Consumer<? super U> disposer, boolean eager) (package private)
UsingSingleObserver
(SingleObserver<? super T> actual, U resource, boolean eager, Consumer<? super U> disposer) -
Uses of Consumer in io.reactivex.rxjava3.internal.subscribers
Fields in io.reactivex.rxjava3.internal.subscribers declared as ConsumerModifier and TypeFieldDescriptionBoundedSubscriber.onError
DisposableAutoReleaseSubscriber.onError
ForEachWhileSubscriber.onError
LambdaSubscriber.onError
BoundedSubscriber.onNext
DisposableAutoReleaseSubscriber.onNext
LambdaSubscriber.onNext
(package private) final Consumer
<? super org.reactivestreams.Subscription> BoundedSubscriber.onSubscribe
(package private) final Consumer
<? super org.reactivestreams.Subscription> LambdaSubscriber.onSubscribe
Constructors in io.reactivex.rxjava3.internal.subscribers with parameters of type ConsumerModifierConstructorDescriptionBoundedSubscriber
(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super org.reactivestreams.Subscription> onSubscribe, int bufferSize) DisposableAutoReleaseSubscriber
(DisposableContainer composite, Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) ForEachWhileSubscriber
(Predicate<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) LambdaSubscriber
(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super org.reactivestreams.Subscription> onSubscribe) -
Uses of Consumer in io.reactivex.rxjava3.internal.util
Classes in io.reactivex.rxjava3.internal.util that implement ConsumerModifier and TypeClassDescriptionfinal class
Stores an incoming Throwable (if any) and counts itself down.final class
Store the Disposable received from the connection. -
Uses of Consumer in io.reactivex.rxjava3.observables
Methods in io.reactivex.rxjava3.observables with parameters of type ConsumerModifier and TypeMethodDescriptionConnectableObservable.autoConnect
(int numberOfObservers, @NonNull Consumer<? super Disposable> connection) Returns anObservable
that automatically connects (at most once) to thisConnectableObservable
when the specified number ofObserver
s subscribe to it and calls the specified callback with theDisposable
associated with the established connection.abstract void
ConnectableObservable.connect
(@NonNull Consumer<? super Disposable> connection) Instructs theConnectableObservable
to begin emitting the items from its underlyingObservable
to itsObserver
s. -
Uses of Consumer in io.reactivex.rxjava3.parallel
Methods in io.reactivex.rxjava3.parallel with parameters of type ConsumerModifier and TypeMethodDescriptionfinal @NonNull ParallelFlowable
<T> ParallelFlowable.doAfterNext
(@NonNull Consumer<? super @NonNull T> onAfterNext) Call the specified consumer with the current element passing through any 'rail' after it has been delivered to downstream within the rail.final @NonNull ParallelFlowable
<T> Call the specified consumer with the exception passing through any 'rail'.final @NonNull ParallelFlowable
<T> Call the specified consumer with the current element passing through any 'rail'.final @NonNull ParallelFlowable
<T> ParallelFlowable.doOnNext
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull BiFunction<? super Long, ? super Throwable, ParallelFailureHandling> errorHandler) Call the specified consumer with the current element passing through any 'rail' and handles errors based on the returned value by the handler function.final @NonNull ParallelFlowable
<T> ParallelFlowable.doOnNext
(@NonNull Consumer<? super @NonNull T> onNext, @NonNull ParallelFailureHandling errorHandler) Call the specified consumer with the current element passing through any 'rail' and handles errors based on the givenParallelFailureHandling
enumeration value.final @NonNull ParallelFlowable
<T> ParallelFlowable.doOnSubscribe
(@NonNull Consumer<? super org.reactivestreams.Subscription> onSubscribe) Call the specified callback when a 'rail' receives aSubscription
from its upstream. -
Uses of Consumer in io.reactivex.rxjava3.plugins
Fields in io.reactivex.rxjava3.plugins declared as ConsumerMethods in io.reactivex.rxjava3.plugins that return ConsumerMethods in io.reactivex.rxjava3.plugins with parameters of type ConsumerModifier and TypeMethodDescriptionstatic void
RxJavaPlugins.setErrorHandler
(@Nullable Consumer<? super Throwable> handler) Sets the specific hook function.