SubmissionPublisher 构造函数
定义
重要
一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。 对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。
重载
| SubmissionPublisher() |
使用 |
| SubmissionPublisher(IExecutor, Int32) |
使用给定的执行程序创建一个新的 SubmissionPublisher，以便将异步传送到订阅服务器，每个订阅服务器的最大缓冲区大小，并且方法 |
| SubmissionPublisher(IntPtr, JniHandleOwnership) | |
| SubmissionPublisher(IExecutor, Int32, IBiConsumer) |
使用给定的 CommitPublisher 创建一个新的 SubmissionPublisher，以便将异步传送到订阅服务器，为每个订阅服务器提供给定的最大缓冲区大小;如果为非 null，则当任何订阅服务器在方法 |
SubmissionPublisher()
使用 ForkJoinPool#commonPool() 异步传送到订阅服务器（除非它不支持至少两个并行级别（在这种情况下，将创建一个新线程来运行每个任务），并且其缓冲区容量 Flow#defaultBufferSize最大，并且方法 Flow.Subscriber#onNext(Object) onNext中没有订阅服务器异常的处理程序。
[Android.Runtime.Register(".ctor", "()V", "", ApiSince=33)]
public SubmissionPublisher ();- 属性
注解
使用 ForkJoinPool#commonPool() 异步传送到订阅服务器（除非它不支持至少两个并行级别（在这种情况下，将创建一个新线程来运行每个任务），并且其缓冲区容量 Flow#defaultBufferSize最大，并且方法 Flow.Subscriber#onNext(Object) onNext中没有订阅服务器异常的处理程序。
适用于 . 的 java.util.concurrent.SubmissionPublisher.SubmissionPublisher()Java 文档
本页的某些部分是根据 Android 开放源代码项目创建和共享的工作进行的修改，并根据 Creative Commons 2.5 属性许可证中所述的术语使用。
适用于
SubmissionPublisher(IExecutor, Int32)
使用给定的执行程序创建一个新的 SubmissionPublisher，以便将异步传送到订阅服务器，每个订阅服务器的最大缓冲区大小，并且方法 Flow.Subscriber#onNext(Object) onNext中没有订阅服务器异常的处理程序。
[Android.Runtime.Register(".ctor", "(Ljava/util/concurrent/Executor;I)V", "", ApiSince=33)]
public SubmissionPublisher (Java.Util.Concurrent.IExecutor? executor, int maxBufferCapacity);[<Android.Runtime.Register(".ctor", "(Ljava/util/concurrent/Executor;I)V", "", ApiSince=33)>]
new Java.Util.Concurrent.SubmissionPublisher : Java.Util.Concurrent.IExecutor * int -> Java.Util.Concurrent.SubmissionPublisher参数
- executor
- IExecutor
用于异步传递的执行程序，支持创建至少一个独立线程
- maxBufferCapacity
- Int32
每个订阅服务器的缓冲区的最大容量（强制容量可以向上舍入为最接近的两个和/或受此实现支持的最大值限制）;方法 #getMaxBufferCapacity 返回实际值）
- 属性
注解
使用给定的执行程序创建一个新的 SubmissionPublisher，以便将异步传送到订阅服务器，每个订阅服务器的最大缓冲区大小，并且方法 Flow.Subscriber#onNext(Object) onNext中没有订阅服务器异常的处理程序。
本页的某些部分是根据 Android 开放源代码项目创建和共享的工作进行的修改，并根据 Creative Commons 2.5 属性许可证中所述的术语使用。
适用于
SubmissionPublisher(IntPtr, JniHandleOwnership)
protected SubmissionPublisher (IntPtr javaReference, Android.Runtime.JniHandleOwnership transfer);new Java.Util.Concurrent.SubmissionPublisher : nativeint * Android.Runtime.JniHandleOwnership -> Java.Util.Concurrent.SubmissionPublisher参数
- javaReference
-
IntPtr
nativeint
- transfer
- JniHandleOwnership
适用于
SubmissionPublisher(IExecutor, Int32, IBiConsumer)
使用给定的 CommitPublisher 创建一个新的 SubmissionPublisher，以便将异步传送到订阅服务器，为每个订阅服务器提供给定的最大缓冲区大小;如果为非 null，则当任何订阅服务器在方法 Flow.Subscriber#onNext(Object) onNext中引发异常时调用给定处理程序。
[Android.Runtime.Register(".ctor", "(Ljava/util/concurrent/Executor;ILjava/util/function/BiConsumer;)V", "", ApiSince=33)]
public SubmissionPublisher (Java.Util.Concurrent.IExecutor? executor, int maxBufferCapacity, Java.Util.Functions.IBiConsumer? handler);[<Android.Runtime.Register(".ctor", "(Ljava/util/concurrent/Executor;ILjava/util/function/BiConsumer;)V", "", ApiSince=33)>]
new Java.Util.Concurrent.SubmissionPublisher : Java.Util.Concurrent.IExecutor * int * Java.Util.Functions.IBiConsumer -> Java.Util.Concurrent.SubmissionPublisher参数
- executor
- IExecutor
用于异步传递的执行程序，支持创建至少一个独立线程
- maxBufferCapacity
- Int32
每个订阅服务器的缓冲区的最大容量（强制容量可以向上舍入为最接近的两个和/或受此实现支持的最大值限制）;方法 #getMaxBufferCapacity 返回实际值）
- handler
- IBiConsumer
如果为非 null，则为在方法中引发的异常时调用的过程 onNext
- 属性
注解
使用给定的 CommitPublisher 创建一个新的 SubmissionPublisher，以便将异步传送到订阅服务器，为每个订阅服务器提供给定的最大缓冲区大小;如果为非 null，则当任何订阅服务器在方法 Flow.Subscriber#onNext(Object) onNext中引发异常时调用给定处理程序。
本页的某些部分是根据 Android 开放源代码项目创建和共享的工作进行的修改，并根据 Creative Commons 2.5 属性许可证中所述的术语使用。