インターフェース ReactiveScriptExecutor<K>

型パラメーター:
K - スクリプトの実行中に渡される可能性のあるキーの型
すべての既知の実装クラス:
DefaultReactiveScriptExecutor

public interface ReactiveScriptExecutor<K>
リアクティブインフラストラクチャを使用して RedisScript を実行します。

Reactive Streams が null 値の使用を禁止しているため、RedisElementReader.read(ByteBuffer) が特定の要素に対して null を返す場合、Mono<K> または Flux<M> を返すメソッドのストリームは InvalidDataAccessApiUsageException で終了します。

導入:
2.0
作成者:
Mark Paluch, Christoph Strobl
  • メソッドの詳細

    • execute

      default <T> reactor.core.publisher.Flux<T> execute(RedisScript<T> script)
      指定された RedisScript を実行します
      パラメーター:
      script - null であってはなりません。
      戻り値:
      スクリプトの戻り値、または RedisScript.getResultType() が null の場合は Flux.empty()、おそらく使い捨てのステータス応答を示す (つまり、"OK" )
    • execute

      default <T> reactor.core.publisher.Flux<T> execute(RedisScript<T> script, ListSE<K> keys)
      指定された RedisScript を実行します
      パラメーター:
      script - null であってはなりません。
      keys - null であってはなりません。
      戻り値:
      スクリプトの戻り値、または RedisScript.getResultType() が null の場合は Flux.empty()、おそらく使い捨てのステータス応答を示す (つまり、"OK" )
    • execute

      <T> reactor.core.publisher.Flux<T> execute(RedisScript<T> script, ListSE<K> keys, ListSE<?> args)
      指定された RedisScript を実行します
      パラメーター:
      script - 実行するスクリプト。null であってはなりません。
      keys - スクリプトに渡す必要のあるすべてのキー。null であってはなりません。
      args - スクリプトに渡す必要のある引数。空にすることができます。
      戻り値:
      スクリプトの戻り値、または RedisScript.getResultType() が null の場合は Flux.empty()。これは、使い捨てのステータス応答を示している可能性があります。(つまり、"OK" )
    • execute

      <T> reactor.core.publisher.Flux<T> execute(RedisScript<T> script, ListSE<K> keys, ListSE<?> args, RedisElementWriter<?> argsWriter, RedisElementReader<T> resultReader)
      指定された RedisSerializer を使用して、指定された RedisScript を実行し、スクリプトの引数と結果を直列化します。
      パラメーター:
      script - 実行するスクリプト。null であってはなりません。
      keys - スクリプトに渡す必要のあるキー
      args - スクリプトに渡す必要のある引数
      argsWriter - 引数の直列化に使用する RedisElementWriter。null であってはなりません。
      resultReader - スクリプトの戻り値を直列化するために使用する RedisElementReader。null であってはなりません。
      戻り値:
      スクリプトの戻り値、または RedisScript.getResultType() が null の場合は Flux.empty()。これは、使い捨てのステータス応答を示している可能性があります。(つまり、"OK" )