インターフェース ReactiveSetOperations<K,V>


public interface ReactiveSetOperations<K,V>
Set コマンドに対するリアクティブな Redis 操作。

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

導入:
2.0
作成者:
Mark Paluch, Christoph Strobl, Roman Bezpalko
関連事項:
  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    reactor.core.publisher.Mono<LongSE>
    add(K key, V... values)
    指定された values を key に設定するために追加します。
    reactor.core.publisher.Mono<BooleanSE>
    delete(K key)
    指定されたキーを削除します。
    reactor.core.publisher.Flux<V>
    指定された keys のすべてのセットを差分します。
    reactor.core.publisher.Flux<V>
    difference(K key, CollectionSE<K> otherKeys)
    指定された key および otherKeys のすべてのセットを差分します。
    reactor.core.publisher.Flux<V>
    difference(K key, K otherKey)
    指定された key および otherKey のすべてのセットを差分します。
    reactor.core.publisher.Mono<LongSE>
    指定された keys のすべてのセットを差分し、結果を destKey に格納します。
    reactor.core.publisher.Mono<LongSE>
    differenceAndStore(K key, CollectionSE<K> otherKeys, K destKey)
    指定された key および otherKeys のすべてのセットを差分し、結果を destKey に格納します。
    reactor.core.publisher.Mono<LongSE>
    differenceAndStore(K key, K otherKey, K destKey)
    指定された key および otherKey のすべてのセットを差分し、結果を destKey に格納します。
    reactor.core.publisher.Flux<V>
    distinctRandomMembers(K key, long count)
    key に設定されているから count の個別のランダム要素を取得します。
    reactor.core.publisher.Flux<V>
    keys で指定されたすべてのセットと交差するメンバーを返します。
    reactor.core.publisher.Flux<V>
    intersect(K key, CollectionSE<K> otherKeys)
    key および otherKeys で指定されたすべてのセットと交差するメンバーを返します。
    reactor.core.publisher.Flux<V>
    intersect(K key, K otherKey)
    key および otherKey で指定されたすべてのセットと交差するメンバーを返します。
    reactor.core.publisher.Mono<LongSE>
    指定されたすべてのセットを keys で交差させ、結果を destKey に格納します。
    reactor.core.publisher.Mono<LongSE>
    intersectAndStore(K key, CollectionSE<K> otherKeys, K destKey)
    指定されたすべてのセットを key と otherKeys で交差させ、結果を destKey に格納します。
    reactor.core.publisher.Mono<LongSE>
    intersectAndStore(K key, K otherKey, K destKey)
    指定されたすべてのセットを key と otherKey で交差させ、結果を destKey に格納します。
    reactor.core.publisher.Mono<BooleanSE>
    key に設定されているものに value が含まれているか確認してください。
    reactor.core.publisher.Mono<MapSE<ObjectSE,BooleanSE>>
    isMember(K key, ObjectSE... objects)
    key に設定されているものに 1 つ以上の values が含まれているかどうかを確認します。
    reactor.core.publisher.Flux<V>
    members(K key)
    セットのすべての要素を key で取得します。
    reactor.core.publisher.Mono<BooleanSE>
    move(K sourceKey, V value, K destKey)
    value を key から destKey に移動します
    reactor.core.publisher.Mono<V>
    pop(K key)
    key のセットからランダムなメンバーを削除して返します。
    reactor.core.publisher.Flux<V>
    pop(K key, long count)
    key のセットから count ランダムメンバーを削除して返します。
    reactor.core.publisher.Mono<V>
    key のセットからランダム要素を取得します。
    reactor.core.publisher.Flux<V>
    randomMembers(K key, long count)
    key のセットから count ランダム要素を取得します。
    reactor.core.publisher.Mono<LongSE>
    remove(K key, ObjectSE... values)
    指定された values を key のセットから削除し、削除された要素の数を返します。
    default reactor.core.publisher.Flux<V>
    scan(K key)
    Flux を使用して、key のセット内のエントリを反復処理します。
    reactor.core.publisher.Flux<V>
    scan(K key, ScanOptions options)
    Flux を使用して、ScanOptions が指定された key のセット内のエントリを反復処理します。
    reactor.core.publisher.Mono<LongSE>
    size(K key)
    セットのサイズを key で取得します。
    reactor.core.publisher.Flux<V>
    指定された keys ですべてのセットを結合します。
    reactor.core.publisher.Flux<V>
    union(K key, CollectionSE<K> otherKeys)
    指定された keys および otherKeys ですべてのセットを結合します。
    reactor.core.publisher.Flux<V>
    union(K key, K otherKey)
    指定された keys および otherKey ですべてのセットを結合します。
    reactor.core.publisher.Mono<LongSE>
    unionAndStore(CollectionSE<K> keys, K destKey)
    指定された keys ですべてのセットを結合し、結果を destKey に格納します。
    reactor.core.publisher.Mono<LongSE>
    unionAndStore(K key, CollectionSE<K> otherKeys, K destKey)
    指定された key および otherKeys ですべてのセットを結合し、結果を destKey に格納します。
    reactor.core.publisher.Mono<LongSE>
    unionAndStore(K key, K otherKey, K destKey)
    指定された key および otherKey ですべてのセットを結合し、結果を destKey に格納します。
  • メソッドの詳細

    • add

      reactor.core.publisher.Mono<LongSE> add(K key, V... values)
      指定された values を key に設定するために追加します。
      パラメーター:
      key - null であってはなりません。
      values -
      戻り値:
      関連事項:
    • remove

      reactor.core.publisher.Mono<LongSE> remove(K key, ObjectSE... values)
      指定された values を key のセットから削除し、削除された要素の数を返します。
      パラメーター:
      key - null であってはなりません。
      values -
      戻り値:
      関連事項:
    • pop

      reactor.core.publisher.Mono<V> pop(K key)
      key のセットからランダムなメンバーを削除して返します。
      パラメーター:
      key - null であってはなりません。
      戻り値:
      関連事項:
    • pop

      reactor.core.publisher.Flux<V> pop(K key, long count)
      key のセットから count ランダムメンバーを削除して返します。
      パラメーター:
      key - null であってはなりません。
      count - セットからポップするランダムメンバーの数。
      戻り値:
      Flux はランダムなメンバーを放出します。
      関連事項:
    • move

      reactor.core.publisher.Mono<BooleanSE> move(K sourceKey, V value, K destKey)
      value を key から destKey に移動します
      パラメーター:
      sourceKey - null であってはなりません。
      value -
      destKey - null であってはなりません。
      戻り値:
      関連事項:
    • size

      reactor.core.publisher.Mono<LongSE> size(K key)
      セットのサイズを key で取得します。
      パラメーター:
      key - null であってはなりません。
      戻り値:
      関連事項:
    • isMember

      reactor.core.publisher.Mono<BooleanSE> isMember(K key, ObjectSE o)
      key に設定されているものに value が含まれているか確認してください。
      パラメーター:
      key - null であってはなりません。
      o -
      戻り値:
      関連事項:
    • isMember

      reactor.core.publisher.Mono<MapSE<ObjectSE,BooleanSE>> isMember(K key, ObjectSE... objects)
      key に設定されているものに 1 つ以上の values が含まれているかどうかを確認します。
      パラメーター:
      key - null であってはなりません。
      objects -
      戻り値:
      導入:
      2.6
      関連事項:
    • intersect

      reactor.core.publisher.Flux<V> intersect(K key, K otherKey)
      key および otherKey で指定されたすべてのセットと交差するメンバーを返します。
      パラメーター:
      key - null であってはなりません。
      otherKey - null であってはなりません。
      戻り値:
      関連事項:
    • intersect

      reactor.core.publisher.Flux<V> intersect(K key, CollectionSE<K> otherKeys)
      key および otherKeys で指定されたすべてのセットと交差するメンバーを返します。
      パラメーター:
      key - null であってはなりません。
      otherKeys - null であってはなりません。
      戻り値:
      関連事項:
    • intersect

      reactor.core.publisher.Flux<V> intersect(CollectionSE<K> keys)
      keys で指定されたすべてのセットと交差するメンバーを返します。
      パラメーター:
      keys - null であってはなりません。
      戻り値:
      導入:
      2.2
      関連事項:
    • intersectAndStore

      reactor.core.publisher.Mono<LongSE> intersectAndStore(K key, K otherKey, K destKey)
      指定されたすべてのセットを key と otherKey で交差させ、結果を destKey に格納します。
      パラメーター:
      key - null であってはなりません。
      otherKey - null であってはなりません。
      destKey - null であってはなりません。
      戻り値:
      関連事項:
    • intersectAndStore

      reactor.core.publisher.Mono<LongSE> intersectAndStore(K key, CollectionSE<K> otherKeys, K destKey)
      指定されたすべてのセットを key と otherKeys で交差させ、結果を destKey に格納します。
      パラメーター:
      key - null であってはなりません。
      otherKeys - null であってはなりません。
      destKey - null であってはなりません。
      戻り値:
      関連事項:
    • intersectAndStore

      reactor.core.publisher.Mono<LongSE> intersectAndStore(CollectionSE<K> keys, K destKey)
      指定されたすべてのセットを keys で交差させ、結果を destKey に格納します。
      パラメーター:
      keys - null であってはなりません。
      destKey - null であってはなりません。
      戻り値:
      導入:
      2.2
      関連事項:
    • union

      reactor.core.publisher.Flux<V> union(K key, K otherKey)
      指定された keys および otherKey ですべてのセットを結合します。
      パラメーター:
      key - null であってはなりません。
      otherKey - null であってはなりません。
      戻り値:
      関連事項:
    • union

      reactor.core.publisher.Flux<V> union(K key, CollectionSE<K> otherKeys)
      指定された keys および otherKeys ですべてのセットを結合します。
      パラメーター:
      key - null であってはなりません。
      otherKeys - null であってはなりません。
      戻り値:
      関連事項:
    • union

      reactor.core.publisher.Flux<V> union(CollectionSE<K> keys)
      指定された keys ですべてのセットを結合します。
      パラメーター:
      keys - null であってはなりません。
      戻り値:
      導入:
      2.2
      関連事項:
    • unionAndStore

      reactor.core.publisher.Mono<LongSE> unionAndStore(K key, K otherKey, K destKey)
      指定された key および otherKey ですべてのセットを結合し、結果を destKey に格納します。
      パラメーター:
      key - null であってはなりません。
      otherKey - null であってはなりません。
      destKey - null であってはなりません。
      戻り値:
      関連事項:
    • unionAndStore

      reactor.core.publisher.Mono<LongSE> unionAndStore(K key, CollectionSE<K> otherKeys, K destKey)
      指定された key および otherKeys ですべてのセットを結合し、結果を destKey に格納します。
      パラメーター:
      key - null であってはなりません。
      otherKeys - null であってはなりません。
      destKey - null であってはなりません。
      戻り値:
      関連事項:
    • unionAndStore

      reactor.core.publisher.Mono<LongSE> unionAndStore(CollectionSE<K> keys, K destKey)
      指定された keys ですべてのセットを結合し、結果を destKey に格納します。
      パラメーター:
      keys - null であってはなりません。
      destKey - null であってはなりません。
      戻り値:
      導入:
      2.2
      関連事項:
    • difference

      reactor.core.publisher.Flux<V> difference(K key, K otherKey)
      指定された key および otherKey のすべてのセットを差分します。
      パラメーター:
      key - null であってはなりません。
      otherKey - null であってはなりません。
      戻り値:
      関連事項:
    • difference

      reactor.core.publisher.Flux<V> difference(K key, CollectionSE<K> otherKeys)
      指定された key および otherKeys のすべてのセットを差分します。
      パラメーター:
      key - null であってはなりません。
      otherKeys - null であってはなりません。
      戻り値:
      関連事項:
    • difference

      reactor.core.publisher.Flux<V> difference(CollectionSE<K> keys)
      指定された keys のすべてのセットを差分します。
      パラメーター:
      keys - null であってはなりません。
      戻り値:
      導入:
      2.2
      関連事項:
    • differenceAndStore

      reactor.core.publisher.Mono<LongSE> differenceAndStore(K key, K otherKey, K destKey)
      指定された key および otherKey のすべてのセットを差分し、結果を destKey に格納します。
      パラメーター:
      key - null であってはなりません。
      otherKey - null であってはなりません。
      destKey - null であってはなりません。
      戻り値:
      関連事項:
    • differenceAndStore

      reactor.core.publisher.Mono<LongSE> differenceAndStore(K key, CollectionSE<K> otherKeys, K destKey)
      指定された key および otherKeys のすべてのセットを差分し、結果を destKey に格納します。
      パラメーター:
      key - null であってはなりません。
      otherKeys - null であってはなりません。
      destKey - null であってはなりません。
      戻り値:
      関連事項:
    • differenceAndStore

      reactor.core.publisher.Mono<LongSE> differenceAndStore(CollectionSE<K> keys, K destKey)
      指定された keys のすべてのセットを差分し、結果を destKey に格納します。
      パラメーター:
      keys - null であってはなりません。
      destKey - null であってはなりません。
      戻り値:
      導入:
      2.2
      関連事項:
    • members

      reactor.core.publisher.Flux<V> members(K key)
      セットのすべての要素を key で取得します。
      パラメーター:
      key - null であってはなりません。
      戻り値:
      関連事項:
    • scan

      default reactor.core.publisher.Flux<V> scan(K key)
      Flux を使用して、key のセット内のエントリを反復処理します。結果の Flux はカーソルとして機能し、サブスクライバーが要求を通知する限り、SSCAN コマンド自体を発行します。
      パラメーター:
      key - null であってはなりません。
      戻り値:
      Flux は値を 1 つずつ出力するか、存在しない場合は empty Flux を出力します。
      例外:
      IllegalArgumentExceptionSE - key が指定された場合は null です。
      導入:
      2.1
      関連事項:
    • scan

      reactor.core.publisher.Flux<V> scan(K key, ScanOptions options)
      Flux を使用して、ScanOptions が指定された key のセット内のエントリを反復処理します。結果の Flux はカーソルとして機能し、サブスクライバーが要求を通知する限り、SSCAN コマンド自体を発行します。
      パラメーター:
      key - null であってはなりません。
      options - null であってはなりません。代わりに ScanOptions.NONE を使用してください。
      戻り値:
      Flux は値を 1 つずつ出力するか、キーが存在しない場合は empty Flux を出力します。
      例外:
      IllegalArgumentExceptionSE - 必要な引数の 1 つが null の場合。
      導入:
      2.1
      関連事項:
    • randomMember

      reactor.core.publisher.Mono<V> randomMember(K key)
      key のセットからランダム要素を取得します。
      パラメーター:
      key - null であってはなりません。
      戻り値:
      関連事項:
    • distinctRandomMembers

      reactor.core.publisher.Flux<V> distinctRandomMembers(K key, long count)
      key に設定されているから count の個別のランダム要素を取得します。
      パラメーター:
      key - null であってはなりません。
      count - 戻るメンバーの数。
      戻り値:
      関連事項:
    • randomMembers

      reactor.core.publisher.Flux<V> randomMembers(K key, long count)
      key のセットから count ランダム要素を取得します。
      パラメーター:
      key - null であってはなりません。
      count - 戻るメンバーの数。
      戻り値:
      関連事項:
    • delete

      reactor.core.publisher.Mono<BooleanSE> delete(K key)
      指定されたキーを削除します。
      パラメーター:
      key - null であってはなりません。