語言

SubmissionPublisher.Consume(IConsumer) 方法

定義

使用給定的消費者函數處理所有已發佈的項目。

[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,當出版商發出 onComplete 信號時正常完成,且在任何錯誤或取消時例外

屬性

備註

使用給定的消費者函數處理所有已發佈的項目。 回傳一個通常在發布者發出信號 Flow.Subscriber#onComplete() onComplete時完成的 CompletableFuture,或在出現錯誤、消費者拋出例外時異常完成,或回傳的 CompletableFuture 被取消(此時不再處理項目)。

的 java.util.concurrent.SubmissionPublisher.consume(java.util.function.Consumer<? super T>)Java 檔。

本頁部分內容為基於 Open Source Project 所創建與分享的作品,並依授權條款所描述的使用進行修改。

適用於