Interface RedisSetReactiveCommands<K,​V>

    • Method Detail

      • sadd

        Mono<Long> sadd​(K key,
                        V... members)
        Add one or more members to a set.
        Parameters:
        key - the key.
        members - the member type: value.
        Returns:
        Long integer-reply the number of elements that were added to the set, not including all the elements already present into the set.
      • scard

        Mono<Long> scard​(K key)
        Get the number of members in a set.
        Parameters:
        key - the key.
        Returns:
        Long integer-reply the cardinality (number of elements) of the set, or false if key does not exist.
      • sdiff

        Flux<V> sdiff​(K... keys)
        Subtract multiple sets.
        Parameters:
        keys - the key.
        Returns:
        V array-reply list with members of the resulting set.
      • sdiff

        @Deprecated
        Mono<Long> sdiff​(ValueStreamingChannel<V> channel,
                         K... keys)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by sdiff(K...).
        Subtract multiple sets.
        Parameters:
        channel - the channel.
        keys - the keys.
        Returns:
        Long count of members of the resulting set.
      • sdiffstore

        Mono<Long> sdiffstore​(K destination,
                              K... keys)
        Subtract multiple sets and store the resulting set in a key.
        Parameters:
        destination - the destination type: key.
        keys - the key.
        Returns:
        Long integer-reply the number of elements in the resulting set.
      • sinter

        Flux<V> sinter​(K... keys)
        Intersect multiple sets.
        Parameters:
        keys - the key.
        Returns:
        V array-reply list with members of the resulting set.
      • sinter

        @Deprecated
        Mono<Long> sinter​(ValueStreamingChannel<V> channel,
                          K... keys)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by sinter(K...).
        Intersect multiple sets.
        Parameters:
        channel - the channel.
        keys - the keys.
        Returns:
        Long count of members of the resulting set.
      • sintercard

        Mono<Long> sintercard​(K... keys)
        This command works exactly like sinter(java.lang.Object[]) but instead of returning the result set, it returns just the cardinality of the result.
        Parameters:
        keys - the keys.
        Returns:
        The cardinality of the set which would result from the intersection of all the given sets.
        Since:
        6.2
      • sintercard

        Mono<Long> sintercard​(long limit,
                              K... keys)
        This command works exactly like sinter(java.lang.Object[]) but instead of returning the result set, it returns just the cardinality of the result.
        Parameters:
        limit - If the intersection cardinality reaches limit partway through the computation, the algorithm will exit and yield limit as the cardinality.
        keys - the keys.
        Returns:
        The cardinality of the set which would result from the intersection of all the given sets.
        Since:
        6.2
      • sinterstore

        Mono<Long> sinterstore​(K destination,
                               K... keys)
        Intersect multiple sets and store the resulting set in a key.
        Parameters:
        destination - the destination type: key.
        keys - the key.
        Returns:
        Long integer-reply the number of elements in the resulting set.
      • sismember

        Mono<Boolean> sismember​(K key,
                                V member)
        Determine if a given value is a member of a set.
        Parameters:
        key - the key.
        member - the member type: value.
        Returns:
        Boolean integer-reply specifically: true if the element is a member of the set. false if the element is not a member of the set, or if key does not exist.
      • smembers

        Flux<V> smembers​(K key)
        Get all the members in a set.
        Parameters:
        key - the key.
        Returns:
        V array-reply all elements of the set.
      • smembers

        @Deprecated
        Mono<Long> smembers​(ValueStreamingChannel<V> channel,
                            K key)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by smembers(K).
        Get all the members in a set.
        Parameters:
        channel - the channel.
        key - the keys.
        Returns:
        Long count of members of the resulting set.
      • smismember

        Flux<Boolean> smismember​(K key,
                                 V... members)
        Returns whether each member is a member of the set stored at key.
        Parameters:
        key - the key.
        members - the member type: value.
        Returns:
        Boolean array-reply list representing the membership of the given elements, in the same order as they are requested.
        Since:
        6.1
      • smove

        Mono<Boolean> smove​(K source,
                            K destination,
                            V member)
        Move a member from one set to another.
        Parameters:
        source - the source key.
        destination - the destination type: key.
        member - the member type: value.
        Returns:
        Boolean integer-reply specifically: true if the element is moved. false if the element is not a member of source and no operation was performed.
      • spop

        Mono<V> spop​(K key)
        Remove and return a random member from a set.
        Parameters:
        key - the key.
        Returns:
        V bulk-string-reply the removed element, or null when key does not exist.
      • spop

        Flux<V> spop​(K key,
                     long count)
        Remove and return one or multiple random members from a set.
        Parameters:
        key - the key.
        count - number of members to pop.
        Returns:
        V bulk-string-reply the removed element, or null when key does not exist.
      • srandmember

        Mono<V> srandmember​(K key)
        Get one random member from a set.
        Parameters:
        key - the key.
        Returns:
        V bulk-string-reply without the additional count argument the command returns a Bulk Reply with the randomly selected element, or null when key does not exist.
      • srandmember

        Flux<V> srandmember​(K key,
                            long count)
        Get one or multiple random members from a set.
        Parameters:
        key - the key.
        count - the count type: long.
        Returns:
        V bulk-string-reply without the additional count argument the command returns a Bulk Reply with the randomly selected element, or null when key does not exist.
      • srandmember

        @Deprecated
        Mono<Long> srandmember​(ValueStreamingChannel<V> channel,
                               K key,
                               long count)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by srandmember(K).
        Get one or multiple random members from a set.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        count - the count.
        Returns:
        Long count of members of the resulting set.
      • srem

        Mono<Long> srem​(K key,
                        V... members)
        Remove one or more members from a set.
        Parameters:
        key - the key.
        members - the member type: value.
        Returns:
        Long integer-reply the number of members that were removed from the set, not including non existing members.
      • sunion

        Flux<V> sunion​(K... keys)
        Add multiple sets.
        Parameters:
        keys - the key.
        Returns:
        V array-reply list with members of the resulting set.
      • sunion

        @Deprecated
        Mono<Long> sunion​(ValueStreamingChannel<V> channel,
                          K... keys)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by sunion(K...).
        Add multiple sets.
        Parameters:
        channel - streaming channel that receives a call for every value.
        keys - the keys.
        Returns:
        Long count of members of the resulting set.
      • sunionstore

        Mono<Long> sunionstore​(K destination,
                               K... keys)
        Add multiple sets and store the resulting set in a key.
        Parameters:
        destination - the destination type: key.
        keys - the key.
        Returns:
        Long integer-reply the number of elements in the resulting set.
      • sscan

        Mono<ValueScanCursor<V>> sscan​(K key)
        Incrementally iterate Set elements.
        Parameters:
        key - the key.
        Returns:
        ValueScanCursor<V> scan cursor.
      • sscan

        Mono<ValueScanCursor<V>> sscan​(K key,
                                       ScanArgs scanArgs)
        Incrementally iterate Set elements.
        Parameters:
        key - the key.
        scanArgs - scan arguments.
        Returns:
        ValueScanCursor<V> scan cursor.
      • sscan

        Mono<ValueScanCursor<V>> sscan​(K key,
                                       ScanCursor scanCursor,
                                       ScanArgs scanArgs)
        Incrementally iterate Set elements.
        Parameters:
        key - the key.
        scanCursor - cursor to resume from a previous scan, must not be null.
        scanArgs - scan arguments.
        Returns:
        ValueScanCursor<V> scan cursor.
      • sscan

        Mono<ValueScanCursor<V>> sscan​(K key,
                                       ScanCursor scanCursor)
        Incrementally iterate Set elements.
        Parameters:
        key - the key.
        scanCursor - cursor to resume from a previous scan, must not be null.
        Returns:
        ValueScanCursor<V> scan cursor.
      • sscan

        @Deprecated
        Mono<StreamScanCursor> sscan​(ValueStreamingChannel<V> channel,
                                     K key)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by sscan(K).
        Incrementally iterate Set elements.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        Returns:
        StreamScanCursor scan cursor.
      • sscan

        @Deprecated
        Mono<StreamScanCursor> sscan​(ValueStreamingChannel<V> channel,
                                     K key,
                                     ScanArgs scanArgs)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by sscan(K).
        Incrementally iterate Set elements.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        scanArgs - scan arguments.
        Returns:
        StreamScanCursor scan cursor.
      • sscan

        @Deprecated
        Mono<StreamScanCursor> sscan​(ValueStreamingChannel<V> channel,
                                     K key,
                                     ScanCursor scanCursor,
                                     ScanArgs scanArgs)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by sscan(K).
        Incrementally iterate Set elements.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        scanCursor - cursor to resume from a previous scan, must not be null.
        scanArgs - scan arguments.
        Returns:
        StreamScanCursor scan cursor.
      • sscan

        @Deprecated
        Mono<StreamScanCursor> sscan​(ValueStreamingChannel<V> channel,
                                     K key,
                                     ScanCursor scanCursor)
        Deprecated.
        since 6.0 in favor of consuming large results through the Publisher returned by sscan(K).
        Incrementally iterate Set elements.
        Parameters:
        channel - streaming channel that receives a call for every value.
        key - the key.
        scanCursor - cursor to resume from a previous scan, must not be null.
        Returns:
        StreamScanCursor scan cursor.