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.util.concurrent.SubmissionPublisher.SubmissionPublisher()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 は実際の値を返します)。

属性

RegisterAttribute

注釈

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

の java.util.concurrent.SubmissionPublisher.SubmissionPublisher(java.util.concurrent.Executor, int)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

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.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 ドキュメント。

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