SubmissionPublisher コンストラクター

定義

名前空間:

Java.Util.Concurrent

アセンブリ:

Mono.Android.dll

オーバーロード

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 ();

属性

RegisterAttribute

注釈

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

の Java ドキュメントjava.util.concurrent.SubmissionPublisher.SubmissionPublisher()

このページの一部は、Android オープンソース プロジェクトによって作成および共有され、クリエイティブ コモンズ 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

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

maxBufferCapacity

Int32

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

属性

RegisterAttribute

注釈

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

の Java ドキュメントjava.util.concurrent.SubmissionPublisher.SubmissionPublisher(java.util.concurrent.Executor, int)

このページの一部は、Android オープンソース プロジェクトによって作成および共有され、クリエイティブ コモンズ 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

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

maxBufferCapacity

Int32

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

handler

IBiConsumer

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

属性

RegisterAttribute

注釈

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

の Java ドキュメント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>)

このページの一部は、Android オープンソース プロジェクトによって作成および共有され、クリエイティブ コモンズ 2.5 属性ライセンスに記載されている条件に従って使用される作業に基づく変更です。