SubmissionPublisher 建構函式
定義
重要
部分資訊涉及發行前產品，在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊，不做任何明確或隱含的瑕疵擔保。
多載
| 名稱 | Description |
|---|---|
| SubmissionPublisher() |
使用 for |
| SubmissionPublisher(IExecutor, Int32) |
使用給定的執行器建立新的 SubmissionPublisher，進行非同步傳遞給訂閱者，每個訂閱者擁有最大緩衝區大小，且方法中不包含訂閱者例外 |
| SubmissionPublisher(IntPtr, JniHandleOwnership) | |
| SubmissionPublisher(IExecutor, Int32, IBiConsumer) |
使用給定的執行器建立新的 SubmissionPublisher，進行非同步傳遞給訂閱者，每個訂閱者的最大緩衝區大小為指定，若非空，則當任何訂閱者在方法 |
SubmissionPublisher()
使用 for ForkJoinPool#commonPool() async 傳送給訂閱者（除非不支援至少二級平行處理，則需建立新執行緒執行每個任務），最大緩衝容量為 Flow#defaultBufferSize，且方法中不設訂閱者例外 Flow.Subscriber#onNext(Object) onNext處理程序。
[Android.Runtime.Register(".ctor", "()V", "", ApiSince=33)]
public SubmissionPublisher();- 屬性
備註
使用 for ForkJoinPool#commonPool() async 傳送給訂閱者（除非不支援至少二級平行處理，則需建立新執行緒執行每個任務），最大緩衝容量為 Flow#defaultBufferSize，且方法中不設訂閱者例外 Flow.Subscriber#onNext(Object) onNext處理程序。
Java 文件 java.util.concurrent.SubmissionPublisher.SubmissionPublisher()。
本頁部分內容為基於 Open Source Project 所創建與分享的作品，並依授權條款所描述的使用進行修改。
適用於
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的處理器。
本頁部分內容為基於 Open Source Project 所創建與分享的作品，並依授權條款所描述的使用進行修改。
適用於
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)
使用給定的執行器建立新的 SubmissionPublisher，進行非同步傳遞給訂閱者，每個訂閱者的最大緩衝區大小為指定，若非空，則當任何訂閱者在方法 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
若非空，則在方法中拋出異常呼叫程序 onNext
- 屬性
備註
使用給定的執行器建立新的 SubmissionPublisher，進行非同步傳遞給訂閱者，每個訂閱者的最大緩衝區大小為指定，若非空，則當任何訂閱者在方法 Flow.Subscriber#onNext(Object) onNext中拋出例外時，會呼叫該處理器。
本頁部分內容為基於 Open Source Project 所創建與分享的作品，並依授權條款所描述的使用進行修改。