Teilen über

SubmissionPublisher Konstruktoren

  • Referenz

Definition

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

Überlädt

SubmissionPublisher()

Erstellt einen neuen SubmissionPublisher unter Verwendung der ForkJoinPool#commonPool() asynchronen Übermittlung an Abonnenten (es sei denn, es unterstützt keine Parallelitätsstufe von mindestens zwei, in diesem Fall wird ein neuer Thread erstellt, um jede Aufgabe auszuführen), mit maximaler Pufferkapazität von Flow#defaultBufferSize, und kein Handler für Abonnentenausnahmen in der Methode Flow.Subscriber#onNext(Object) onNext.
SubmissionPublisher(IExecutor, Int32)

Erstellt einen neuen SubmissionPublisher mit dem angegebenen Executor für die asynchrone Übermittlung an Abonnenten mit der angegebenen maximalen Puffergröße für jeden Abonnenten und keinen Handler für Abonnentenausnahmen in der Methode Flow.Subscriber#onNext(Object) onNext.
SubmissionPublisher(IntPtr, JniHandleOwnership)
SubmissionPublisher(IExecutor, Int32, IBiConsumer)

Erstellt einen neuen SubmissionPublisher mit dem angegebenen Executor für die asynchrone Übermittlung an Abonnenten, mit der angegebenen maximalen Puffergröße für jeden Abonnent, und wenn der angegebene Handler nicht null ist, wird der angegebene Handler aufgerufen, wenn ein Subscriber eine Ausnahme in der Methode Flow.Subscriber#onNext(Object) onNextauslöst.

SubmissionPublisher()

Erstellt einen neuen SubmissionPublisher unter Verwendung der ForkJoinPool#commonPool() asynchronen Übermittlung an Abonnenten (es sei denn, es unterstützt keine Parallelitätsstufe von mindestens zwei, in diesem Fall wird ein neuer Thread erstellt, um jede Aufgabe auszuführen), mit maximaler Pufferkapazität von Flow#defaultBufferSize, und kein Handler für Abonnentenausnahmen in der Methode Flow.Subscriber#onNext(Object) onNext.

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

Hinweise

Erstellt einen neuen SubmissionPublisher unter Verwendung der ForkJoinPool#commonPool() asynchronen Übermittlung an Abonnenten (es sei denn, es unterstützt keine Parallelitätsstufe von mindestens zwei, in diesem Fall wird ein neuer Thread erstellt, um jede Aufgabe auszuführen), mit maximaler Pufferkapazität von Flow#defaultBufferSize, und kein Handler für Abonnentenausnahmen in der Methode Flow.Subscriber#onNext(Object) onNext.

Java-Dokumentation für java.util.concurrent.SubmissionPublisher.SubmissionPublisher().

Teile dieser Seite sind Änderungen auf der Grundlage von Arbeiten, die vom Android Open Source-Projekt erstellt und freigegeben werden und gemäß den in der Creative Commons 2.5 Attribution License beschriebenen Begriffen verwendet werden.

Gilt für:

SubmissionPublisher(IExecutor, Int32)

Erstellt einen neuen SubmissionPublisher mit dem angegebenen Executor für die asynchrone Übermittlung an Abonnenten mit der angegebenen maximalen Puffergröße für jeden Abonnenten und keinen Handler für Abonnentenausnahmen in der Methode 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

Parameter

executor
IExecutor

der für die asynchrone Übermittlung zu verwendende Executor, der die Erstellung von mindestens einem unabhängigen Thread unterstützt

maxBufferCapacity
Int32

die maximale Kapazität für den Puffer jedes Abonnenten (die erzwungene Kapazität kann auf die nächste Leistung von zwei und/oder an den größten Wert gerundet werden, der von dieser Implementierung unterstützt wird; Methode #getMaxBufferCapacity gibt den tatsächlichen Wert zurück)

Attribute
RegisterAttribute

Hinweise

Erstellt einen neuen SubmissionPublisher mit dem angegebenen Executor für die asynchrone Übermittlung an Abonnenten mit der angegebenen maximalen Puffergröße für jeden Abonnenten und keinen Handler für Abonnentenausnahmen in der Methode Flow.Subscriber#onNext(Object) onNext.

Java-Dokumentation für java.util.concurrent.SubmissionPublisher.SubmissionPublisher(java.util.concurrent.Executor, int).

Teile dieser Seite sind Änderungen auf der Grundlage von Arbeiten, die vom Android Open Source-Projekt erstellt und freigegeben werden und gemäß den in der Creative Commons 2.5 Attribution License beschriebenen Begriffen verwendet werden.

Gilt für:

SubmissionPublisher(IntPtr, JniHandleOwnership) 

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

Parameter

javaReference
IntPtr

nativeint
transfer
JniHandleOwnership

Gilt für:

SubmissionPublisher(IExecutor, Int32, IBiConsumer)

Erstellt einen neuen SubmissionPublisher mit dem angegebenen Executor für die asynchrone Übermittlung an Abonnenten, mit der angegebenen maximalen Puffergröße für jeden Abonnent, und wenn der angegebene Handler nicht null ist, wird der angegebene Handler aufgerufen, wenn ein Subscriber eine Ausnahme in der Methode Flow.Subscriber#onNext(Object) onNextauslöst.

[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

Parameter

executor
IExecutor

der für die asynchrone Übermittlung zu verwendende Executor, der die Erstellung von mindestens einem unabhängigen Thread unterstützt

maxBufferCapacity
Int32

die maximale Kapazität für den Puffer jedes Abonnenten (die erzwungene Kapazität kann auf die nächste Leistung von zwei und/oder an den größten Wert gerundet werden, der von dieser Implementierung unterstützt wird; Methode #getMaxBufferCapacity gibt den tatsächlichen Wert zurück)

handler
IBiConsumer

wenn nicht NULL, Prozedur, die beim Auslösen einer Ausnahme in der Methode aufgerufen werden soll onNext

Attribute
RegisterAttribute

Hinweise

Erstellt einen neuen SubmissionPublisher mit dem angegebenen Executor für die asynchrone Übermittlung an Abonnenten, mit der angegebenen maximalen Puffergröße für jeden Abonnent, und wenn der angegebene Handler nicht null ist, wird der angegebene Handler aufgerufen, wenn ein Subscriber eine Ausnahme in der Methode Flow.Subscriber#onNext(Object) onNextauslöst.

Java-Dokumentation für 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>).

Teile dieser Seite sind Änderungen auf der Grundlage von Arbeiten, die vom Android Open Source-Projekt erstellt und freigegeben werden und gemäß den in der Creative Commons 2.5 Attribution License beschriebenen Begriffen verwendet werden.

Gilt für: