Top Description Methods

io.reactivex.rxjava3.functions

public Interface Consumer<T>

Known Direct Implementers

io.reactivex.rxjava3.internal.functions.Functions.NotificationOnNext, io.reactivex.rxjava3.internal.functions.Functions.NotificationOnError, io.reactivex.rxjava3.internal.functions.Functions.ActionConsumer, io.reactivex.rxjava3.internal.functions.Functions.EmptyConsumer, io.reactivex.rxjava3.internal.functions.Functions.ErrorConsumer, io.reactivex.rxjava3.internal.functions.Functions.OnErrorMissingConsumer, io.reactivex.rxjava3.internal.functions.Functions.MaxRequestSubscription, io.reactivex.rxjava3.internal.functions.Functions.BoundedConsumer, io.reactivex.rxjava3.internal.operators.flowable.FlowableOnBackpressureDrop, io.reactivex.rxjava3.internal.operators.flowable.FlowableGroupBy.EvictionAction, io.reactivex.rxjava3.internal.operators.flowable.FlowableInternalHelper.SubscriberOnNext, io.reactivex.rxjava3.internal.operators.flowable.FlowableInternalHelper.SubscriberOnError, io.reactivex.rxjava3.internal.operators.flowable.FlowableInternalHelper.RequestMax, io.reactivex.rxjava3.internal.operators.flowable.FlowableRefCount.RefConnection, io.reactivex.rxjava3.internal.operators.flowable.FlowableReplay.MulticastFlowable.DisposableConsumer, io.reactivex.rxjava3.internal.operators.observable.ObservableRefCount.RefConnection, io.reactivex.rxjava3.internal.operators.observable.ObservableReplay.DisposeConsumer, io.reactivex.rxjava3.internal.operators.observable.ObservableInternalHelper.ObserverOnNext, io.reactivex.rxjava3.internal.operators.observable.ObservableInternalHelper.ObserverOnError, io.reactivex.rxjava3.internal.util.BlockingIgnoringReceiver, io.reactivex.rxjava3.internal.util.ConnectConsumer

Annotations

@FunctionalInterface

Type Parameters

<T>: the value type

Imports

io.reactivex.rxjava3.annotations.NonNull

A functional interface (callback) that accepts a single value.

Method Summary

Modifier and Type	Method and Description
public void	accept(T the value t) Consume the given value.

Method Detail

accept

back to summary

public void accept(T t) throws Throwable

Consume the given value.

Parameters

t:T: the value

Exceptions

Throwable:: if the implementation wishes to throw any type of exception