Compartir a través de


SubmissionPublisher Constructores

Definición

Sobrecargas

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.

Documentación de Java para java.util.concurrent.SubmissionPublisher.SubmissionPublisher().

Las partes de esta página son modificaciones basadas en el trabajo creado y compartido por el proyecto de código abierto de Android y se usan según los términos descritos en la licencia de atribución de Creative Commons 2.5.

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.

Documentación de Java 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 proyecto de código abierto de Android y se usan según los términos descritos en la licencia de atribución de Creative Commons 2.5.

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.

Documentación de Java 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 proyecto de código abierto de Android y se usan según los términos descritos en la licencia de atribución de Creative Commons 2.5.

Se aplica a