パッケージ org.springframework.core
クラス CoroutinesUtils
java.lang.ObjectSE
org.springframework.core.CoroutinesUtils
Kotlin コルーチンを操作するためのユーティリティ。
- 導入:
- 5.2
- 作成者:
- Sebastien Deleuze, Phillip Webb
コンストラクターのサマリー
メソッドのサマリー
修飾子と型メソッド説明static <T> reactor.core.publisher.Mono<T>
deferredToMono
(kotlinx.coroutines.Deferred<T> source) Deferred
インスタンスをMono
に変換します。static Publisher<?>
invokeSuspendingFunction
(MethodSE method, ObjectSE target, ObjectSE... args) サスペンド関数を呼び出し、それをMono
またはFlux
に変換します。static Publisher<?>
invokeSuspendingFunction
(kotlin.coroutines.CoroutineContext context, MethodSE method, ObjectSE target, ObjectSE... args) サスペンド関数を呼び出し、それをMono
またはFlux
に変換します。static <T> kotlinx.coroutines.Deferred<T>
monoToDeferred
(reactor.core.publisher.Mono<T> source) Mono
インスタンスをDeferred
に変換します。
コンストラクターの詳細
CoroutinesUtils
public CoroutinesUtils()
メソッドの詳細
deferredToMono
public static <T> reactor.core.publisher.Mono<T> deferredToMono(kotlinx.coroutines.Deferred<T> source) Deferred
インスタンスをMono
に変換します。monoToDeferred
public static <T> kotlinx.coroutines.Deferred<T> monoToDeferred(reactor.core.publisher.Mono<T> source) Mono
インスタンスをDeferred
に変換します。invokeSuspendingFunction
public static Publisher<?> invokeSuspendingFunction(MethodSE method, ObjectSE target, @Nullable ObjectSE... args) サスペンド関数を呼び出し、それをMono
またはFlux
に変換します。制限のないディスパッチャーを使用します。- パラメーター:
method
- 呼び出すサスペンド関数target
-method
を呼び出すターゲットargs
- 関数の引数。Continuation
引数が最後の引数 (通常はnull
) として指定されている場合、無視されます。- 戻り値:
- リアクティブストリームとしてのメソッド呼び出し結果
- 例外:
IllegalArgumentExceptionSE
-method
がサスペンド関数でない場合
invokeSuspendingFunction
public static Publisher<?> invokeSuspendingFunction(kotlin.coroutines.CoroutineContext context, MethodSE method, @Nullable ObjectSE target, @Nullable ObjectSE... args) サスペンド関数を呼び出し、それをMono
またはFlux
に変換します。- パラメーター:
context
- 使用するコルーチンコンテキストmethod
- 呼び出すサスペンド関数target
-method
を呼び出すターゲットargs
- 関数の引数。Continuation
引数が最後の引数 (通常はnull
) として指定されている場合、無視されます。- 戻り値:
- リアクティブストリームとしてのメソッド呼び出し結果
- 例外:
IllegalArgumentExceptionSE
-method
がサスペンド関数でない場合- 導入:
- 6.0