SubmissionPublisher Конструкторы

Определение

Пространство имен:

Java.Util.Concurrent

Сборка:

Mono.Android.dll

Перегрузки

SubmissionPublisher()	Создает новый объект SubmissionPublisher с помощью ForkJoinPool#commonPool() асинхронной доставки подписчикам (если он не поддерживает уровень параллелизма не менее двух, в этом случае создается новый поток для выполнения каждой задачи), с максимальной емкостью Flow#defaultBufferSizeбуфера и без обработчика исключений подписчиков в методе Flow.Subscriber#onNext(Object) onNext.
SubmissionPublisher(IExecutor, Int32)	Создает новый объект SubmissionPublisher с помощью заданного исполнителя для асинхронной доставки подписчикам, с заданным максимальным размером буфера для каждого подписчика и без обработчика исключений подписчиков в методе Flow.Subscriber#onNext(Object) onNext.
SubmissionPublisher(IntPtr, JniHandleOwnership)
SubmissionPublisher(IExecutor, Int32, IBiConsumer)	Создает новый объект SubmissionPublisher с помощью заданного исполнителя для асинхронной доставки подписчикам, с заданным максимальным размером буфера для каждого подписчика, и, если не имеет значения NULL, этот обработчик вызывается, когда любой подписчик создает исключение в методе Flow.Subscriber#onNext(Object) onNext.

SubmissionPublisher()

Создает новый объект SubmissionPublisher с помощью ForkJoinPool#commonPool() асинхронной доставки подписчикам (если он не поддерживает уровень параллелизма не менее двух, в этом случае создается новый поток для выполнения каждой задачи), с максимальной емкостью Flow#defaultBufferSizeбуфера и без обработчика исключений подписчиков в методе Flow.Subscriber#onNext(Object) onNext.

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

Атрибуты

RegisterAttribute

Комментарии

Создает новый объект SubmissionPublisher с помощью ForkJoinPool#commonPool() асинхронной доставки подписчикам (если он не поддерживает уровень параллелизма не менее двух, в этом случае создается новый поток для выполнения каждой задачи), с максимальной емкостью Flow#defaultBufferSizeбуфера и без обработчика исключений подписчиков в методе Flow.Subscriber#onNext(Object) onNext.

Документация по Java для java.util.concurrent.SubmissionPublisher.SubmissionPublisher().

Части этой страницы — это изменения на основе работы, созданной и общей проектом с открытым исходным кодом Android и используемой в соответствии с условиями, описанными в лицензии Creative Commons 2.5 Attribution.

SubmissionPublisher(IExecutor, Int32)

Создает новый объект 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

Комментарии

Создает новый объект SubmissionPublisher с помощью заданного исполнителя для асинхронной доставки подписчикам, с заданным максимальным размером буфера для каждого подписчика и без обработчика исключений подписчиков в методе Flow.Subscriber#onNext(Object) onNext.

Документация по Java для java.util.concurrent.SubmissionPublisher.SubmissionPublisher(java.util.concurrent.Executor, int).

Части этой страницы — это изменения на основе работы, созданной и общей проектом с открытым исходным кодом Android и используемой в соответствии с условиями, описанными в лицензии Creative Commons 2.5 Attribution.

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)

Создает новый объект 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

Комментарии

Создает новый объект 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 и используемой в соответствии с условиями, описанными в лицензии Creative Commons 2.5 Attribution.