SubmissionPublisher Construtores

Definição

Sobrecargas

Nome Description
SubmissionPublisher()

Cria um novo SubmissionPublisher usando a ForkJoinPool#commonPool() entrega assíncrona para assinantes (a menos que não dê suporte a um nível de paralelismo de pelo menos dois, nesse caso, um novo Thread é criado para executar cada tarefa), com capacidade máxima de buffer e Flow#defaultBufferSizenenhum 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 nulo, o manipulador determinado invocado quando qualquer Assinante lança uma exceção no método Flow.Subscriber#onNext(Object) onNext.

SubmissionPublisher()

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

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

Comentários

Cria um novo SubmissionPublisher usando a ForkJoinPool#commonPool() entrega assíncrona para assinantes (a menos que não dê suporte a um nível de paralelismo de pelo menos dois, nesse caso, um novo Thread é criado para executar cada tarefa), com capacidade máxima de buffer e Flow#defaultBufferSizenenhum 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 Project Open Source do Open Source e usadas de acordo com os termos descritos na Creative Commons 2.5.

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 até a potência mais próxima de dois e/ou limitada pelo maior valor suportado por essa implementação; o método #getMaxBufferCapacity retorna o valor real)

Atributos

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 Project Open Source do Open Source e usadas de acordo com os termos descritos na Creative Commons 2.5.

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

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 nulo, o manipulador determinado 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 até a potência mais próxima de dois e/ou limitada pelo maior valor suportado por essa implementação; o método #getMaxBufferCapacity retorna o valor real)

handler
IBiConsumer

se não for nulo, o procedimento a ser invocado após a exceção gerada no método onNext

Atributos

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 nulo, o manipulador determinado 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 Project Open Source do Open Source e usadas de acordo com os termos descritos na Creative Commons 2.5.

Aplica-se a