SubmissionPublisher 建構函式

定義

命名空間:

Java.Util.Concurrent

組件:

Mono.Android.dll

多載

SubmissionPublisher()	使用 ForkJoinPool#commonPool() 異步傳遞至訂閱者建立新的 SubmissionPublisher （除非它不支援至少兩個平行處理原則層級，在此情況下，會建立新的 Thread 來執行每個工作），且緩衝區容量 Flow#defaultBufferSize上限為 ，而且方法 Flow.Subscriber#onNext(Object) onNext中沒有訂閱者例外狀況的處理程式。
SubmissionPublisher(IExecutor, Int32)	使用指定的 Executor 將異步傳遞至訂閱者，為每個訂閱者建立新的 SubmissionPublisher，並針對每個訂閱者指定緩衝區大小上限，而且 方法 Flow.Subscriber#onNext(Object) onNext中沒有訂閱者例外狀況的處理程式。
SubmissionPublisher(IntPtr, JniHandleOwnership)
SubmissionPublisher(IExecutor, Int32, IBiConsumer)	使用指定的 Executor 來建立新的 SubmissionPublisher，以便將異步傳遞至訂閱者，並針對每個訂閱者指定緩衝區大小上限，如果不是 Null，則當任何訂閱者在 方法 Flow.Subscriber#onNext(Object) onNext中擲回例外狀況時叫用的指定處理程式。

SubmissionPublisher()

使用 ForkJoinPool#commonPool() 異步傳遞至訂閱者建立新的 SubmissionPublisher （除非它不支援至少兩個平行處理原則層級，在此情況下，會建立新的 Thread 來執行每個工作），且緩衝區容量 Flow#defaultBufferSize上限為 ，而且方法 Flow.Subscriber#onNext(Object) onNext中沒有訂閱者例外狀況的處理程式。

[Android.Runtime.Register(".ctor", "()V", "", ApiSince=33)]
public SubmissionPublisher ();

屬性

RegisterAttribute

備註

使用 ForkJoinPool#commonPool() 異步傳遞至訂閱者建立新的 SubmissionPublisher （除非它不支援至少兩個平行處理原則層級，在此情況下，會建立新的 Thread 來執行每個工作），且緩衝區容量 Flow#defaultBufferSize上限為 ，而且方法 Flow.Subscriber#onNext(Object) onNext中沒有訂閱者例外狀況的處理程式。

的 java.util.concurrent.SubmissionPublisher.SubmissionPublisher()Java 檔。

此頁面的部分是根據 Android 開放原始碼專案所建立和共用的工作進行修改，並根據 Creative Commons 2.5 屬性授權中所述的詞彙使用。

SubmissionPublisher(IExecutor, Int32)

使用指定的 Executor 將異步傳遞至訂閱者，為每個訂閱者建立新的 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 會傳回實際值）

屬性

RegisterAttribute

備註

使用指定的 Executor 將異步傳遞至訂閱者，為每個訂閱者建立新的 SubmissionPublisher，並針對每個訂閱者指定緩衝區大小上限，而且 方法 Flow.Subscriber#onNext(Object) onNext中沒有訂閱者例外狀況的處理程式。

的 java.util.concurrent.SubmissionPublisher.SubmissionPublisher(java.util.concurrent.Executor, int)Java 檔。

此頁面的部分是根據 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)

使用指定的 Executor 來建立新的 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

屬性

RegisterAttribute

備註

使用指定的 Executor 來建立新的 SubmissionPublisher，以便將異步傳遞至訂閱者，並針對每個訂閱者指定緩衝區大小上限，如果不是 Null，則當任何訂閱者在 方法 Flow.Subscriber#onNext(Object) onNext中擲回例外狀況時叫用的指定處理程式。

的 java.util.concurrent.SubmissionPublisher.SubmissionPublisher(java.util.concurrent.Executor, int, java.util.function.BiConsumer<? super java.util.concurrent.Flow.Subscriber<? super T>, ? super java.lang.Throwable>)Java 檔。

此頁面的部分是根據 Android 開放原始碼專案所建立和共用的工作進行修改，並根據 Creative Commons 2.5 屬性授權中所述的詞彙使用。