Condividi tramite


SubmissionPublisher Costruttori

Definizione

Overload

SubmissionPublisher()

Crea un nuovo oggetto SubmissionPublisher usando per il ForkJoinPool#commonPool() recapito asincrono ai sottoscrittori (a meno che non supporti un livello di parallelismo di almeno due, nel qual caso viene creato un nuovo thread per eseguire ogni attività), con capacità massima di buffer di Flow#defaultBufferSizee nessun gestore per le eccezioni del Sottoscrittore nel metodo Flow.Subscriber#onNext(Object) onNext.

SubmissionPublisher(IExecutor, Int32)

Crea un nuovo Oggetto SubmissionPublisher usando l'executor specificato per il recapito asincrono ai sottoscrittori, con le dimensioni massime del buffer specificate per ogni sottoscrittore e nessun gestore per le eccezioni del Sottoscrittore nel metodo Flow.Subscriber#onNext(Object) onNext.

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

Crea un nuovo oggetto SubmissionPublisher usando l'executor specificato per il recapito asincrono ai sottoscrittori, con le dimensioni massime del buffer specificate per ogni sottoscrittore e, se non Null, il gestore specificato richiamato quando un Sottoscrittore genera un'eccezione nel metodo Flow.Subscriber#onNext(Object) onNext.

SubmissionPublisher()

Crea un nuovo oggetto SubmissionPublisher usando per il ForkJoinPool#commonPool() recapito asincrono ai sottoscrittori (a meno che non supporti un livello di parallelismo di almeno due, nel qual caso viene creato un nuovo thread per eseguire ogni attività), con capacità massima di buffer di Flow#defaultBufferSizee nessun gestore per le eccezioni del Sottoscrittore nel metodo Flow.Subscriber#onNext(Object) onNext.

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

Commenti

Crea un nuovo oggetto SubmissionPublisher usando per il ForkJoinPool#commonPool() recapito asincrono ai sottoscrittori (a meno che non supporti un livello di parallelismo di almeno due, nel qual caso viene creato un nuovo thread per eseguire ogni attività), con capacità massima di buffer di Flow#defaultBufferSizee nessun gestore per le eccezioni del Sottoscrittore nel metodo Flow.Subscriber#onNext(Object) onNext.

Documentazione java per java.util.concurrent.SubmissionPublisher.SubmissionPublisher().

Le parti di questa pagina sono modifiche basate sul lavoro creato e condiviso dal progetto Open Source Android e usato in base ai termini descritti nella licenza Creative Commons 2.5 Attribuzione.

Si applica a

SubmissionPublisher(IExecutor, Int32)

Crea un nuovo Oggetto SubmissionPublisher usando l'executor specificato per il recapito asincrono ai sottoscrittori, con le dimensioni massime del buffer specificate per ogni sottoscrittore e nessun gestore per le eccezioni del Sottoscrittore nel metodo 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

Parametri

executor
IExecutor

executor da usare per il recapito asincrono, supportando la creazione di almeno un thread indipendente

maxBufferCapacity
Int32

capacità massima per il buffer di ogni sottoscrittore (la capacità applicata può essere arrotondata alla potenza più vicina di due e/o vincolata dal valore più grande supportato da questa implementazione; il metodo #getMaxBufferCapacity restituisce il valore effettivo)

Attributi

Commenti

Crea un nuovo Oggetto SubmissionPublisher usando l'executor specificato per il recapito asincrono ai sottoscrittori, con le dimensioni massime del buffer specificate per ogni sottoscrittore e nessun gestore per le eccezioni del Sottoscrittore nel metodo Flow.Subscriber#onNext(Object) onNext.

Documentazione java per java.util.concurrent.SubmissionPublisher.SubmissionPublisher(java.util.concurrent.Executor, int).

Le parti di questa pagina sono modifiche basate sul lavoro creato e condiviso dal progetto Open Source Android e usato in base ai termini descritti nella licenza Creative Commons 2.5 Attribuzione.

Si applica 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

Parametri

javaReference
IntPtr

nativeint

Si applica a

SubmissionPublisher(IExecutor, Int32, IBiConsumer)

Crea un nuovo oggetto SubmissionPublisher usando l'executor specificato per il recapito asincrono ai sottoscrittori, con le dimensioni massime del buffer specificate per ogni sottoscrittore e, se non Null, il gestore specificato richiamato quando un Sottoscrittore genera un'eccezione nel metodo 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

Parametri

executor
IExecutor

executor da usare per il recapito asincrono, supportando la creazione di almeno un thread indipendente

maxBufferCapacity
Int32

capacità massima per il buffer di ogni sottoscrittore (la capacità applicata può essere arrotondata alla potenza più vicina di due e/o vincolata dal valore più grande supportato da questa implementazione; il metodo #getMaxBufferCapacity restituisce il valore effettivo)

handler
IBiConsumer

se non null, routine da richiamare al momento dell'eccezione generata nel metodo onNext

Attributi

Commenti

Crea un nuovo oggetto SubmissionPublisher usando l'executor specificato per il recapito asincrono ai sottoscrittori, con le dimensioni massime del buffer specificate per ogni sottoscrittore e, se non Null, il gestore specificato richiamato quando un Sottoscrittore genera un'eccezione nel metodo Flow.Subscriber#onNext(Object) onNext.

Documentazione java per 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>).

Le parti di questa pagina sono modifiche basate sul lavoro creato e condiviso dal progetto Open Source Android e usato in base ai termini descritti nella licenza Creative Commons 2.5 Attribuzione.

Si applica a