Поделиться через

SubmissionPublisher.Consume(IConsumer) Метод

  • Ссылка

Определение

Пространство имен:
Java.Util.Concurrent
Сборка:
Mono.Android.dll

Обрабатывает все опубликованные элементы с помощью данной функции "Потребитель".

[Android.Runtime.Register("consume", "(Ljava/util/function/Consumer;)Ljava/util/concurrent/CompletableFuture;", "GetConsume_Ljava_util_function_Consumer_Handler", ApiSince=33)]
public virtual Java.Util.Concurrent.CompletableFuture? Consume (Java.Util.Functions.IConsumer? consumer);
[<Android.Runtime.Register("consume", "(Ljava/util/function/Consumer;)Ljava/util/concurrent/CompletableFuture;", "GetConsume_Ljava_util_function_Consumer_Handler", ApiSince=33)>]
abstract member Consume : Java.Util.Functions.IConsumer -> Java.Util.Concurrent.CompletableFuture
override this.Consume : Java.Util.Functions.IConsumer -> Java.Util.Concurrent.CompletableFuture

Параметры

consumer
IConsumer

Функция, примененная к каждому элементу onNext

Возвращаемое значение

CompletableFuture

CompleteableFuture, который обычно завершается, когда издатель сигнализирует оcomplete, и исключительно после любой ошибки или отмены

Атрибуты
RegisterAttribute

Комментарии

Обрабатывает все опубликованные элементы с помощью данной функции "Потребитель". Возвращает значение CompleteableFuture, которое обычно завершается, когда этот издатель сигнализирует Flow.Subscriber#onComplete() onCompleteили завершается исключительно по любой ошибке, или исключение вызывается потребителем, или возвращенное завершение CompleteableFuture отменено, в этом случае дальнейшие элементы не обрабатываются.

Документация по Java для java.util.concurrent.SubmissionPublisher.consume(java.util.function.Consumer<? super T>).

Части этой страницы — это изменения на основе работы, созданной и общей проектом с открытым исходным кодом Android и используемой в соответствии с условиями, описанными в лицензии Creative Commons 2.5 Attribution.

Применяется к