Compartilhar via

SubmissionPublisher Construtores

  • Referência

Definição

Namespace:
Java.Util.Concurrent
Assembly:
Mono.Android.dll

Sobrecargas

SubmissionPublisher()

Cria um novo SubmissionPublisher usando o para entrega assíncrona ForkJoinPool#commonPool() para assinantes (a menos que ele não ofereça suporte a um nível de paralelismo de pelo menos dois, caso em que um novo Thread é criado para executar cada tarefa), com capacidade máxima de buffer de Flow#defaultBufferSize, e nenhum manipulador para exceções de Assinante no método Flow.Subscriber#onNext(Object) onNext.
SubmissionPublisher(IExecutor, Int32)

Cria um novo SubmissionPublisher usando o Executor fornecido para entrega assíncrona aos assinantes, com o tamanho máximo de buffer fornecido para cada assinante e nenhum manipulador para exceções de Assinante no método Flow.Subscriber#onNext(Object) onNext.
SubmissionPublisher(IntPtr, JniHandleOwnership)
SubmissionPublisher(IExecutor, Int32, IBiConsumer)

Cria um novo SubmissionPublisher usando o Executor fornecido para entrega assíncrona aos assinantes, com o tamanho máximo de buffer fornecido para cada assinante e, se não for nulo, o manipulador fornecido é invocado quando qualquer Assinante lança uma exceção no método Flow.Subscriber#onNext(Object) onNext.

SubmissionPublisher()

Cria um novo SubmissionPublisher usando o para entrega assíncrona ForkJoinPool#commonPool() para assinantes (a menos que ele não ofereça suporte a um nível de paralelismo de pelo menos dois, caso em que um novo Thread é criado para executar cada tarefa), com capacidade máxima de buffer de Flow#defaultBufferSize, e nenhum manipulador para exceções de Assinante no método Flow.Subscriber#onNext(Object) onNext.

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

Comentários

Cria um novo SubmissionPublisher usando o para entrega assíncrona ForkJoinPool#commonPool() para assinantes (a menos que ele não ofereça suporte a um nível de paralelismo de pelo menos dois, caso em que um novo Thread é criado para executar cada tarefa), com capacidade máxima de buffer de Flow#defaultBufferSize, e nenhum manipulador para exceções de Assinante no método Flow.Subscriber#onNext(Object) onNext.

Documentação Java para java.util.concurrent.SubmissionPublisher.SubmissionPublisher().

Partes desta página são modificações baseadas no trabalho criado e compartilhado pelo Android Open Source Project e usado de acordo com os termos descritos na Creative Commons 2.5 Attribution License.

Aplica-se a

SubmissionPublisher(IExecutor, Int32)

Cria um novo SubmissionPublisher usando o Executor fornecido para entrega assíncrona aos assinantes, com o tamanho máximo de buffer fornecido para cada assinante e nenhum manipulador para exceções de Assinante no 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

o executor a ser usado para entrega assíncrona, dando suporte à criação de pelo menos um thread independente

maxBufferCapacity
Int32

a capacidade máxima para o buffer de cada assinante (a capacidade imposta pode ser arredondada para a potência mais próxima de dois e/ou limitada pelo maior valor suportado por esta implementação; método #getMaxBufferCapacity retorna o valor real)

Atributos
RegisterAttribute

Comentários

Cria um novo SubmissionPublisher usando o Executor fornecido para entrega assíncrona aos assinantes, com o tamanho máximo de buffer fornecido para cada assinante e nenhum manipulador para exceções de Assinante no método Flow.Subscriber#onNext(Object) onNext.

Documentação Java para java.util.concurrent.SubmissionPublisher.SubmissionPublisher(java.util.concurrent.Executor, int).

Partes desta página são modificações baseadas no trabalho criado e compartilhado pelo Android Open Source Project e usado de acordo com os termos descritos na Creative Commons 2.5 Attribution License.

Aplica-se 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
transfer
JniHandleOwnership

Aplica-se a

SubmissionPublisher(IExecutor, Int32, IBiConsumer)

Cria um novo SubmissionPublisher usando o Executor fornecido para entrega assíncrona aos assinantes, com o tamanho máximo de buffer fornecido para cada assinante e, se não for nulo, o manipulador fornecido é invocado quando qualquer Assinante lança uma exceção no 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

o executor a ser usado para entrega assíncrona, dando suporte à criação de pelo menos um thread independente

maxBufferCapacity
Int32

a capacidade máxima para o buffer de cada assinante (a capacidade imposta pode ser arredondada para a potência mais próxima de dois e/ou limitada pelo maior valor suportado por esta implementação; método #getMaxBufferCapacity retorna o valor real)

handler
IBiConsumer

se não for nulo, procedimento a ser invocado sobre a exceção lançada no método onNext

Atributos
RegisterAttribute

Comentários

Cria um novo SubmissionPublisher usando o Executor fornecido para entrega assíncrona aos assinantes, com o tamanho máximo de buffer fornecido para cada assinante e, se não for nulo, o manipulador fornecido é invocado quando qualquer Assinante lança uma exceção no método Flow.Subscriber#onNext(Object) onNext.

Documentação 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>).

Partes desta página são modificações baseadas no trabalho criado e compartilhado pelo Android Open Source Project e usado de acordo com os termos descritos na Creative Commons 2.5 Attribution License.

Aplica-se a