SubmissionPublisher Constructores

Definición

Sobrecargas

Nombre Description
SubmissionPublisher()

Crea un nuevo objeto SubmissionPublisher mediante para ForkJoinPool#commonPool() la entrega asincrónica a los suscriptores (a menos que no admita un nivel de paralelismo de al menos dos, en cuyo caso se crea un nuevo subproceso para ejecutar cada tarea), con capacidad máxima de búfer de Flow#defaultBufferSizey sin controlador para excepciones de suscriptor en el método Flow.Subscriber#onNext(Object) onNext.

SubmissionPublisher(IExecutor, Int32)

Crea un nuevo objeto SubmissionPublisher mediante el ejecutor especificado para la entrega asincrónica a los suscriptores, con el tamaño máximo de búfer especificado para cada suscriptor y ningún controlador para las excepciones de suscriptor en el método Flow.Subscriber#onNext(Object) onNext.

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

Crea un nuevo objeto SubmissionPublisher mediante el ejecutor especificado para la entrega asincrónica a los suscriptores, con el tamaño máximo de búfer especificado para cada suscriptor y, si no es NULL, el controlador especificado invoca cuando cualquier suscriptor produce una excepción en el método Flow.Subscriber#onNext(Object) onNext.

SubmissionPublisher()

Crea un nuevo objeto SubmissionPublisher mediante para ForkJoinPool#commonPool() la entrega asincrónica a los suscriptores (a menos que no admita un nivel de paralelismo de al menos dos, en cuyo caso se crea un nuevo subproceso para ejecutar cada tarea), con capacidad máxima de búfer de Flow#defaultBufferSizey sin controlador para excepciones de suscriptor en el método Flow.Subscriber#onNext(Object) onNext.

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

Comentarios

Crea un nuevo objeto SubmissionPublisher mediante para ForkJoinPool#commonPool() la entrega asincrónica a los suscriptores (a menos que no admita un nivel de paralelismo de al menos dos, en cuyo caso se crea un nuevo subproceso para ejecutar cada tarea), con capacidad máxima de búfer de Flow#defaultBufferSizey sin controlador para excepciones de suscriptor en el método Flow.Subscriber#onNext(Object) onNext.

Java documentación para java.util.concurrent.SubmissionPublisher.SubmissionPublisher().

Las partes de esta página son modificaciones basadas en el trabajo creado y compartido por el Android y se usan según los términos descritos en creative Creative Commons 2.5 Attribution License.

Se aplica a

SubmissionPublisher(IExecutor, Int32)

Crea un nuevo objeto SubmissionPublisher mediante el ejecutor especificado para la entrega asincrónica a los suscriptores, con el tamaño máximo de búfer especificado para cada suscriptor y ningún controlador para las excepciones de suscriptor en el método 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

Parámetros

executor
IExecutor

el ejecutor que se va a usar para la entrega asincrónica, lo que admite la creación de al menos un subproceso independiente

maxBufferCapacity
Int32

la capacidad máxima para el búfer de cada suscriptor (la capacidad aplicada se puede redondear hasta la potencia más cercana de dos o limitadas por el valor más grande admitido por esta implementación; el método #getMaxBufferCapacity devuelve el valor real)

Atributos

Comentarios

Crea un nuevo objeto SubmissionPublisher mediante el ejecutor especificado para la entrega asincrónica a los suscriptores, con el tamaño máximo de búfer especificado para cada suscriptor y ningún controlador para las excepciones de suscriptor en el método Flow.Subscriber#onNext(Object) onNext.

Java documentación para java.util.concurrent.SubmissionPublisher.SubmissionPublisher(java.util.concurrent.Executor, int).

Las partes de esta página son modificaciones basadas en el trabajo creado y compartido por el Android y se usan según los términos descritos en creative Creative Commons 2.5 Attribution License.

Se aplica a

SubmissionPublisher(IntPtr, JniHandleOwnership)

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

Parámetros

javaReference
IntPtr

nativeint

Se aplica a

SubmissionPublisher(IExecutor, Int32, IBiConsumer)

Crea un nuevo objeto SubmissionPublisher mediante el ejecutor especificado para la entrega asincrónica a los suscriptores, con el tamaño máximo de búfer especificado para cada suscriptor y, si no es NULL, el controlador especificado invoca cuando cualquier suscriptor produce una excepción en el método 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

Parámetros

executor
IExecutor

el ejecutor que se va a usar para la entrega asincrónica, lo que admite la creación de al menos un subproceso independiente

maxBufferCapacity
Int32

la capacidad máxima para el búfer de cada suscriptor (la capacidad aplicada se puede redondear hasta la potencia más cercana de dos o limitadas por el valor más grande admitido por esta implementación; el método #getMaxBufferCapacity devuelve el valor real)

handler
IBiConsumer

si no es NULL, procedimiento que se va a invocar tras la excepción iniciada en el método onNext

Atributos

Comentarios

Crea un nuevo objeto SubmissionPublisher mediante el ejecutor especificado para la entrega asincrónica a los suscriptores, con el tamaño máximo de búfer especificado para cada suscriptor y, si no es NULL, el controlador especificado invoca cuando cualquier suscriptor produce una excepción en el método Flow.Subscriber#onNext(Object) onNext.

Java documentación para 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>).

Las partes de esta página son modificaciones basadas en el trabajo creado y compartido por el Android y se usan según los términos descritos en creative Creative Commons 2.5 Attribution License.

Se aplica a