SubmissionPublisher Constructors
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
Overloads
| SubmissionPublisher() |
Creates a new SubmissionPublisher using the |
| SubmissionPublisher(IExecutor, Int32) |
Creates a new SubmissionPublisher using the given Executor for
async delivery to subscribers, with the given maximum buffer size
for each subscriber, and no handler for Subscriber exceptions in
method |
| SubmissionPublisher(IntPtr, JniHandleOwnership) | |
| SubmissionPublisher(IExecutor, Int32, IBiConsumer) |
Creates a new SubmissionPublisher using the given Executor for
async delivery to subscribers, with the given maximum buffer size
for each subscriber, and, if non-null, the given handler invoked
when any Subscriber throws an exception in method |
SubmissionPublisher()
Creates a new SubmissionPublisher using the ForkJoinPool#commonPool() for async delivery to subscribers
(unless it does not support a parallelism level of at least two,
in which case, a new Thread is created to run each task), with
maximum buffer capacity of Flow#defaultBufferSize, and no
handler for Subscriber exceptions in method Flow.Subscriber#onNext(Object) onNext.
[Android.Runtime.Register(".ctor", "()V", "", ApiSince=33)]
public SubmissionPublisher ();- Attributes
Remarks
Creates a new SubmissionPublisher using the ForkJoinPool#commonPool() for async delivery to subscribers (unless it does not support a parallelism level of at least two, in which case, a new Thread is created to run each task), with maximum buffer capacity of Flow#defaultBufferSize, and no handler for Subscriber exceptions in method Flow.Subscriber#onNext(Object) onNext.
Java documentation for java.util.concurrent.SubmissionPublisher.SubmissionPublisher().
Portions of this page are modifications based on work created and shared by the Android Open Source Project and used according to terms described in the Creative Commons 2.5 Attribution License.
Applies to
SubmissionPublisher(IExecutor, Int32)
Creates a new SubmissionPublisher using the given Executor for
async delivery to subscribers, with the given maximum buffer size
for each subscriber, and no handler for Subscriber exceptions in
method 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.SubmissionPublisherParameters
- executor
- IExecutor
the executor to use for async delivery, supporting creation of at least one independent thread
- maxBufferCapacity
- Int32
the maximum capacity for each
subscriber's buffer (the enforced capacity may be rounded up to
the nearest power of two and/or bounded by the largest value
supported by this implementation; method #getMaxBufferCapacity
returns the actual value)
- Attributes
Remarks
Creates a new SubmissionPublisher using the given Executor for async delivery to subscribers, with the given maximum buffer size for each subscriber, and no handler for Subscriber exceptions in method Flow.Subscriber#onNext(Object) onNext.
Portions of this page are modifications based on work created and shared by the Android Open Source Project and used according to terms described in the Creative Commons 2.5 Attribution License.
Applies to
SubmissionPublisher(IntPtr, JniHandleOwnership)
protected SubmissionPublisher (IntPtr javaReference, Android.Runtime.JniHandleOwnership transfer);new Java.Util.Concurrent.SubmissionPublisher : nativeint * Android.Runtime.JniHandleOwnership -> Java.Util.Concurrent.SubmissionPublisherParameters
- javaReference
-
IntPtr
nativeint
- transfer
- JniHandleOwnership
Applies to
SubmissionPublisher(IExecutor, Int32, IBiConsumer)
Creates a new SubmissionPublisher using the given Executor for
async delivery to subscribers, with the given maximum buffer size
for each subscriber, and, if non-null, the given handler invoked
when any Subscriber throws an exception in method 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.SubmissionPublisherParameters
- executor
- IExecutor
the executor to use for async delivery, supporting creation of at least one independent thread
- maxBufferCapacity
- Int32
the maximum capacity for each
subscriber's buffer (the enforced capacity may be rounded up to
the nearest power of two and/or bounded by the largest value
supported by this implementation; method #getMaxBufferCapacity
returns the actual value)
- handler
- IBiConsumer
if non-null, procedure to invoke upon exception
thrown in method onNext
- Attributes
Remarks
Creates a new SubmissionPublisher using the given Executor for async delivery to subscribers, with the given maximum buffer size for each subscriber, and, if non-null, the given handler invoked when any Subscriber throws an exception in method Flow.Subscriber#onNext(Object) onNext.
Portions of this page are modifications based on work created and shared by the Android Open Source Project and used according to terms described in the Creative Commons 2.5 Attribution License.