SubmissionPublisher コンストラクター

定義

オーバーロード

名前 説明
SubmissionPublisher()

サブスクライバーへの非同期配信の ForkJoinPool#commonPool() を使用して新しい SubmissionPublisher を作成します (少なくとも 2 つの並列処理レベルをサポートしていない場合は、各タスクを実行する新しいスレッドが作成されます)。この場合、最大バッファー容量は 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 を作成します (少なくとも 2 つの並列処理レベルをサポートしていない場合は、各タスクを実行する新しいスレッドが作成されます)。この場合、最大バッファー容量は Flow#defaultBufferSize で、メソッド Flow.Subscriber#onNext(Object) onNextのサブスクライバー例外のハンドラーは作成されません。

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

注釈

サブスクライバーへの非同期配信の ForkJoinPool#commonPool() を使用して新しい SubmissionPublisher を作成します (少なくとも 2 つの並列処理レベルをサポートしていない場合は、各タスクを実行する新しいスレッドが作成されます)。この場合、最大バッファー容量は Flow#defaultBufferSize で、メソッド Flow.Subscriber#onNext(Object) onNextのサブスクライバー例外のハンドラーは作成されません。

Javaドキュメント。

このページの一部は、によって作成および共有され、に記載されている条件に従って使用される作業に基づく変更です。

適用対象

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

非同期配信に使用する Executor。少なくとも 1 つの独立したスレッドの作成をサポートします

maxBufferCapacity
Int32

各サブスクライバーのバッファーの最大容量 (適用される容量は、2 の最も近い累乗に切り上げたり、この実装でサポートされている最大値によって制限されたりする可能性があります。メソッド #getMaxBufferCapacity は実際の値を返します)

属性

注釈

サブスクライバーへの非同期配信用に指定された Executor を使用して新しい SubmissionPublisher を作成し、各サブスクライバーに対して指定された最大バッファー サイズを指定し、メソッド Flow.Subscriber#onNext(Object) onNextのサブスクライバー例外のハンドラーを作成しません。

Javaドキュメント。

このページの一部は、によって作成および共有され、に記載されている条件に従って使用される作業に基づく変更です。

適用対象

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

適用対象

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

非同期配信に使用する Executor。少なくとも 1 つの独立したスレッドの作成をサポートします

maxBufferCapacity
Int32

各サブスクライバーのバッファーの最大容量 (適用される容量は、2 の最も近い累乗に切り上げたり、この実装でサポートされている最大値によって制限されたりする可能性があります。メソッド #getMaxBufferCapacity は実際の値を返します)

handler
IBiConsumer

null 以外の場合は、メソッドでスローされた例外時に呼び出すプロシージャ onNext

属性

注釈

サブスクライバーへの非同期配信用に指定された Executor を使用して新しい SubmissionPublisher を作成し、各サブスクライバーの最大バッファー サイズを指定し、null 以外の場合は、サブスクライバーがメソッド Flow.Subscriber#onNext(Object) onNextで例外をスローしたときに呼び出される特定のハンドラーを作成します。

Javaドキュメント。

このページの一部は、によって作成および共有され、に記載されている条件に従って使用される作業に基づく変更です。

適用対象