パッケージ org.springframework.core

クラス CoroutinesUtils

java.lang.ObjectSE
org.springframework.core.CoroutinesUtils
public abstract class CoroutinesUtils extends ObjectSE
Kotlin コルーチンを操作するためのユーティリティ。
導入:
5.2
作成者:
Sebastien Deleuze, Phillip Webb

  • コンストラクターの詳細

    • 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