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

发布者在 OnComplete 发出信号时正常完成的 CompletedableFuture，并在出现任何错误或取消时异常

属性

RegisterAttribute

注解

使用给定的 Consumer 函数处理所有已发布的项。 返回在发布者发出任何错误或 Flow.Subscriber#onComplete() onComplete异常时正常完成的 CompletedableFuture，或者使用者引发异常，或者返回的 CompletedableFuture 被取消，在这种情况下，不会再处理任何项目。

适用于 . 的 java.util.concurrent.SubmissionPublisher.consume(java.util.function.Consumer<? super T>)Java 文档

本页的某些部分是根据 Android 开放源代码项目创建和共享的工作进行的修改，并根据 Creative Commons 2.5 属性许可证中所述的术语使用。