Bagikan melalui


SubmissionPublisher Konstruktor

Definisi

Overload

SubmissionPublisher()

Membuat SubmissionPublisher baru menggunakan ForkJoinPool#commonPool() untuk pengiriman asinkron kepada pelanggan (kecuali tidak mendukung tingkat paralelisme setidaknya dua, dalam hal ini, Thread baru dibuat untuk menjalankan setiap tugas), dengan kapasitas Flow#defaultBufferSizebuffer maksimum , dan tidak ada handler untuk pengecualian Pelanggan dalam metode Flow.Subscriber#onNext(Object) onNext.

SubmissionPublisher(IExecutor, Int32)

Membuat SubmissionPublisher baru menggunakan Pelaksana yang diberikan untuk pengiriman asinkron kepada pelanggan, dengan ukuran buffer maksimum yang diberikan untuk setiap pelanggan, dan tidak ada handler untuk pengecualian Pelanggan dalam metode Flow.Subscriber#onNext(Object) onNext.

SubmissionPublisher(IntPtr, JniHandleOwnership)
SubmissionPublisher(IExecutor, Int32, IBiConsumer)

Membuat SubmissionPublisher baru menggunakan Pelaksana yang diberikan untuk pengiriman asinkron kepada pelanggan, dengan ukuran buffer maksimum yang diberikan untuk setiap pelanggan, dan, jika non-null, handler yang diberikan dipanggil ketika pelanggan melempar pengecualian dalam metode Flow.Subscriber#onNext(Object) onNext.

SubmissionPublisher()

Membuat SubmissionPublisher baru menggunakan ForkJoinPool#commonPool() untuk pengiriman asinkron kepada pelanggan (kecuali tidak mendukung tingkat paralelisme setidaknya dua, dalam hal ini, Thread baru dibuat untuk menjalankan setiap tugas), dengan kapasitas Flow#defaultBufferSizebuffer maksimum , dan tidak ada handler untuk pengecualian Pelanggan dalam metode Flow.Subscriber#onNext(Object) onNext.

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

Keterangan

Membuat SubmissionPublisher baru menggunakan ForkJoinPool#commonPool() untuk pengiriman asinkron kepada pelanggan (kecuali tidak mendukung tingkat paralelisme setidaknya dua, dalam hal ini, Thread baru dibuat untuk menjalankan setiap tugas), dengan kapasitas Flow#defaultBufferSizebuffer maksimum , dan tidak ada handler untuk pengecualian Pelanggan dalam metode Flow.Subscriber#onNext(Object) onNext.

Dokumentasi Java untuk java.util.concurrent.SubmissionPublisher.SubmissionPublisher().

Bagian halaman ini adalah modifikasi berdasarkan pekerjaan yang dibuat dan dibagikan oleh Proyek Sumber Terbuka Android dan digunakan sesuai dengan istilah yang dijelaskan dalam Lisensi Atribusi Creative Commons 2.5.

Berlaku untuk

SubmissionPublisher(IExecutor, Int32)

Membuat SubmissionPublisher baru menggunakan Pelaksana yang diberikan untuk pengiriman asinkron kepada pelanggan, dengan ukuran buffer maksimum yang diberikan untuk setiap pelanggan, dan tidak ada handler untuk pengecualian Pelanggan dalam metode 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

Parameter

executor
IExecutor

pelaksana yang digunakan untuk pengiriman asinkron, mendukung pembuatan setidaknya satu utas independen

maxBufferCapacity
Int32

kapasitas maksimum untuk buffer setiap pelanggan (kapasitas yang diberlakukan dapat dibulatkan ke daya terdekat dua dan/atau dibatasi oleh nilai terbesar yang didukung oleh implementasi ini; metode #getMaxBufferCapacity mengembalikan nilai aktual)

Atribut

Keterangan

Membuat SubmissionPublisher baru menggunakan Pelaksana yang diberikan untuk pengiriman asinkron kepada pelanggan, dengan ukuran buffer maksimum yang diberikan untuk setiap pelanggan, dan tidak ada handler untuk pengecualian Pelanggan dalam metode Flow.Subscriber#onNext(Object) onNext.

Dokumentasi Java untuk java.util.concurrent.SubmissionPublisher.SubmissionPublisher(java.util.concurrent.Executor, int).

Bagian halaman ini adalah modifikasi berdasarkan pekerjaan yang dibuat dan dibagikan oleh Proyek Sumber Terbuka Android dan digunakan sesuai dengan istilah yang dijelaskan dalam Lisensi Atribusi Creative Commons 2.5.

Berlaku untuk

SubmissionPublisher(IntPtr, JniHandleOwnership)

protected SubmissionPublisher (IntPtr javaReference, Android.Runtime.JniHandleOwnership transfer);
new Java.Util.Concurrent.SubmissionPublisher : nativeint * Android.Runtime.JniHandleOwnership -> Java.Util.Concurrent.SubmissionPublisher

Parameter

javaReference
IntPtr

nativeint

Berlaku untuk

SubmissionPublisher(IExecutor, Int32, IBiConsumer)

Membuat SubmissionPublisher baru menggunakan Pelaksana yang diberikan untuk pengiriman asinkron kepada pelanggan, dengan ukuran buffer maksimum yang diberikan untuk setiap pelanggan, dan, jika non-null, handler yang diberikan dipanggil ketika pelanggan melempar pengecualian dalam metode 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

Parameter

executor
IExecutor

pelaksana yang digunakan untuk pengiriman asinkron, mendukung pembuatan setidaknya satu utas independen

maxBufferCapacity
Int32

kapasitas maksimum untuk buffer setiap pelanggan (kapasitas yang diberlakukan dapat dibulatkan ke daya terdekat dua dan/atau dibatasi oleh nilai terbesar yang didukung oleh implementasi ini; metode #getMaxBufferCapacity mengembalikan nilai aktual)

handler
IBiConsumer

jika non-null, prosedur untuk dipanggil setelah pengecualian dilemparkan dalam metode onNext

Atribut

Keterangan

Membuat SubmissionPublisher baru menggunakan Pelaksana yang diberikan untuk pengiriman asinkron kepada pelanggan, dengan ukuran buffer maksimum yang diberikan untuk setiap pelanggan, dan, jika non-null, handler yang diberikan dipanggil ketika pelanggan melempar pengecualian dalam metode Flow.Subscriber#onNext(Object) onNext.

Dokumentasi Java untuk 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>).

Bagian halaman ini adalah modifikasi berdasarkan pekerjaan yang dibuat dan dibagikan oleh Proyek Sumber Terbuka Android dan digunakan sesuai dengan istilah yang dijelaskan dalam Lisensi Atribusi Creative Commons 2.5.

Berlaku untuk