다음을 통해 공유


SubmissionPublisher 생성자

정의

오버로드

SubmissionPublisher()

구독자에 대한 비동기 배달을 사용하여 ForkJoinPool#commonPool() 새 SubmissionPublisher를 만듭니다(이 경우 두 개 이상의 병렬 처리 수준을 지원하지 않는 한, 각 작업을 실행하기 위해 새 스레드가 생성됨) 최대 버퍼 용량 Flow#defaultBufferSize및 메서드 Flow.Subscriber#onNext(Object) onNext에서 구독자 예외에 대한 처리기가 없습니다.

SubmissionPublisher(IExecutor, Int32)

지정된 실행기를 사용하여 구독자에게 비동기 배달을 위한 새 SubmissionPublisher를 만듭니다. 각 구독자에 대해 지정된 최대 버퍼 크기와 메서드 Flow.Subscriber#onNext(Object) onNext에서 구독자 예외에 대한 처리기가 없습니다.

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

각 구독자에 대해 지정된 최대 버퍼 크기를 사용하여 구독자에게 비동기 배달을 위해 지정된 실행기를 사용하여 새 SubmissionPublisher를 만들고, null이 아닌 경우 구독자가 메서드 Flow.Subscriber#onNext(Object) onNext에서 예외를 throw할 때 호출되는 지정된 처리기를 만듭니다.

SubmissionPublisher()

구독자에 대한 비동기 배달을 사용하여 ForkJoinPool#commonPool() 새 SubmissionPublisher를 만듭니다(이 경우 두 개 이상의 병렬 처리 수준을 지원하지 않는 한, 각 작업을 실행하기 위해 새 스레드가 생성됨) 최대 버퍼 용량 Flow#defaultBufferSize및 메서드 Flow.Subscriber#onNext(Object) onNext에서 구독자 예외에 대한 처리기가 없습니다.

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

설명

구독자에 대한 비동기 배달을 사용하여 ForkJoinPool#commonPool() 새 SubmissionPublisher를 만듭니다(이 경우 두 개 이상의 병렬 처리 수준을 지원하지 않는 한, 각 작업을 실행하기 위해 새 스레드가 생성됨) 최대 버퍼 용량 Flow#defaultBufferSize및 메서드 Flow.Subscriber#onNext(Object) onNext에서 구독자 예외에 대한 처리기가 없습니다.

에 대한 java.util.concurrent.SubmissionPublisher.SubmissionPublisher()Java 설명서

이 페이지의 일부는 Android 오픈 소스 프로젝트에서 만들고 공유하고 Creative Commons 2.5 특성 라이선스에 설명된 용어에 따라 사용되는 작업을 기반으로 하는 수정 사항입니다.

적용 대상

SubmissionPublisher(IExecutor, Int32)

지정된 실행기를 사용하여 구독자에게 비동기 배달을 위한 새 SubmissionPublisher를 만듭니다. 각 구독자에 대해 지정된 최대 버퍼 크기와 메서드 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

매개 변수

executor
IExecutor

비동기 배달에 사용할 실행기, 하나 이상의 독립 스레드 만들기 지원

maxBufferCapacity
Int32

각 구독자의 버퍼에 대한 최대 용량(적용된 용량은 2의 가장 가까운 전력으로 반올림되거나 이 구현에서 지원하는 가장 큰 값으로 제한될 수 있습니다. 메서드 #getMaxBufferCapacity 는 실제 값을 반환합니다.)

특성

설명

지정된 실행기를 사용하여 구독자에게 비동기 배달을 위한 새 SubmissionPublisher를 만듭니다. 각 구독자에 대해 지정된 최대 버퍼 크기와 메서드 Flow.Subscriber#onNext(Object) onNext에서 구독자 예외에 대한 처리기가 없습니다.

에 대한 java.util.concurrent.SubmissionPublisher.SubmissionPublisher(java.util.concurrent.Executor, int)Java 설명서

이 페이지의 일부는 Android 오픈 소스 프로젝트에서 만들고 공유하고 Creative Commons 2.5 특성 라이선스에 설명된 용어에 따라 사용되는 작업을 기반으로 하는 수정 사항입니다.

적용 대상

SubmissionPublisher(IntPtr, JniHandleOwnership)

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

매개 변수

javaReference
IntPtr

nativeint

적용 대상

SubmissionPublisher(IExecutor, Int32, IBiConsumer)

각 구독자에 대해 지정된 최대 버퍼 크기를 사용하여 구독자에게 비동기 배달을 위해 지정된 실행기를 사용하여 새 SubmissionPublisher를 만들고, null이 아닌 경우 구독자가 메서드 Flow.Subscriber#onNext(Object) onNext에서 예외를 throw할 때 호출되는 지정된 처리기를 만듭니다.

[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

매개 변수

executor
IExecutor

비동기 배달에 사용할 실행기, 하나 이상의 독립 스레드 만들기 지원

maxBufferCapacity
Int32

각 구독자의 버퍼에 대한 최대 용량(적용된 용량은 2의 가장 가까운 전력으로 반올림되거나 이 구현에서 지원하는 가장 큰 값으로 제한될 수 있습니다. 메서드 #getMaxBufferCapacity 는 실제 값을 반환합니다.)

handler
IBiConsumer

null이 아니면 메서드에서 throw된 예외를 호출하는 프로시저입니다. onNext

특성

설명

각 구독자에 대해 지정된 최대 버퍼 크기를 사용하여 구독자에게 비동기 배달을 위해 지정된 실행기를 사용하여 새 SubmissionPublisher를 만들고, null이 아닌 경우 구독자가 메서드 Flow.Subscriber#onNext(Object) onNext에서 예외를 throw할 때 호출되는 지정된 처리기를 만듭니다.

에 대한 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>)Java 설명서

이 페이지의 일부는 Android 오픈 소스 프로젝트에서 만들고 공유하고 Creative Commons 2.5 특성 라이선스에 설명된 용어에 따라 사용되는 작업을 기반으로 하는 수정 사항입니다.

적용 대상