Share via

SubmissionPublisher.Consume(IConsumer) Метод

  • Ссылка

Определение

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

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

[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, который выполняется обычно, когда издатель сигнализирует onComplete, и в исключительных случаях при любой ошибке или отмене

Атрибуты
RegisterAttribute

Комментарии

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

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

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

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