Uses of Class
org.springframework.data.redis.connection.ReactiveRedisConnection.NumericResponse

Packages that use ReactiveRedisConnection.NumericResponse

Package	Description
org.springframework.data.redis.connection	Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
org.springframework.data.redis.connection.lettuce	Connection package for Lettuce Redis client.

Uses of ReactiveRedisConnection.NumericResponse in org.springframework.data.redis.connection

Methods in org.springframework.data.redis.connection that return types with arguments of type ReactiveRedisConnection.NumericResponse

Modifier and Type	Method and Description
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.AppendCommand,Long>>	ReactiveStringCommands.append(org.reactivestreams.Publisher<ReactiveStringCommands.AppendCommand> commands) Append a ReactiveStringCommands.AppendCommand.getValue() to the ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitCountCommand,Long>>	ReactiveStringCommands.bitCount(org.reactivestreams.Publisher<ReactiveStringCommands.BitCountCommand> commands) Count the number of set bits (population counting) of value stored at key between begin and end.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitOpCommand,Long>>	ReactiveStringCommands.bitOp(org.reactivestreams.Publisher<ReactiveStringCommands.BitOpCommand> commands) Perform bitwise operations between strings.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveNumberCommands.decr(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Decrement value of key by 1.
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.DecrByCommand<T>,T>>	ReactiveNumberCommands.decrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.DecrByCommand<T>> commands) Decrement value of key by value.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveKeyCommands.del(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Delete keys one by one.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoAddCommand,Long>>	ReactiveGeoCommands.geoAdd(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoAddCommand> commands) Add RedisGeoCommands.GeoLocations to key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HDelCommand,Long>>	ReactiveHashCommands.hDel(org.reactivestreams.Publisher<ReactiveHashCommands.HDelCommand> commands) Delete given hash fields.
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.HIncrByCommand<T>,T>>	ReactiveNumberCommands.hIncrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.HIncrByCommand<T>> commands) Increment value of a hash field by the given value.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveHashCommands.hLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get size of hash at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveNumberCommands.incr(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Increment value of key by 1.
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.IncrByCommand<T>,T>>	ReactiveNumberCommands.incrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.IncrByCommand<T>> commands) Increment value of key by value.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LInsertCommand,Long>>	ReactiveListCommands.lInsert(org.reactivestreams.Publisher<ReactiveListCommands.LInsertCommand> commands) Insert ReactiveListCommands.LInsertCommand.getValue() RedisListCommands.Position.BEFORE or RedisListCommands.Position.AFTER existing ReactiveListCommands.LInsertCommand.getPivot() for ReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveListCommands.lLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of list stored at ReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,Long>>	ReactiveListCommands.lRem(org.reactivestreams.Publisher<ReactiveListCommands.LRemCommand> commands) Removes the ReactiveListCommands.LRemCommand.getCount() occurrences of ReactiveListCommands.LRemCommand.getValue() from the list stored at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<List<ByteBuffer>,Long>>	ReactiveKeyCommands.mDel(org.reactivestreams.Publisher<List<ByteBuffer>> keys) Delete multiple keys in batches.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfAddCommand,Long>>	ReactiveHyperLogLogCommands.pfAdd(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfAddCommand> commands) Adds given values to the HyperLogLog stored at given key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfCountCommand,Long>>	ReactiveHyperLogLogCommands.pfCount(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfCountCommand> commands) Return the approximated cardinality of the structures observed by the HyperLogLog at key(s).
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.PushCommand,Long>>	ReactiveListCommands.push(org.reactivestreams.Publisher<ReactiveListCommands.PushCommand> commands) Prepend ReactiveListCommands.PushCommand.getValues() to ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,Long>>	ReactiveSetCommands.sAdd(org.reactivestreams.Publisher<ReactiveSetCommands.SAddCommand> commands) Add given ReactiveSetCommands.SAddCommand.getValues() to set at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveSetCommands.sCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get size of set at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,Long>>	ReactiveSetCommands.sDiffStore(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffStoreCommand> commands) Diff all given sets at keys and store result in destinationKey.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.SetRangeCommand,Long>>	ReactiveStringCommands.setRange(org.reactivestreams.Publisher<ReactiveStringCommands.SetRangeCommand> commands) Overwrite parts of ReactiveRedisConnection.KeyCommand.key starting at the specified offset with given ReactiveStringCommands.SetRangeCommand.value.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,Long>>	ReactiveSetCommands.sInterStore(org.reactivestreams.Publisher<ReactiveSetCommands.SInterStoreCommand> commands) Intersect all given sets at keys and store result in destinationKey.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,Long>>	ReactiveSetCommands.sRem(org.reactivestreams.Publisher<ReactiveSetCommands.SRemCommand> commands) Remove given ReactiveSetCommands.SRemCommand.getValues() from set at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveStringCommands.strLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys) Get the length of the value stored at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,Long>>	ReactiveSetCommands.sUnionStore(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionStoreCommand> commands) Union all given sets at keys and store result in destinationKey.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAddCommand,Number>>	ReactiveZSetCommands.zAdd(org.reactivestreams.Publisher<ReactiveZSetCommands.ZAddCommand> commands) Add ReactiveZSetCommands.ZAddCommand.getTuples() to a sorted set at ReactiveRedisConnection.KeyCommand.getKey(), or update its score if it already exists.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	ReactiveZSetCommands.zCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the size of sorted set with ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZCountCommand,Long>>	ReactiveZSetCommands.zCount(org.reactivestreams.Publisher<ReactiveZSetCommands.ZCountCommand> commands) Count number of elements within sorted set with scores within Range.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZIncrByCommand,Double>>	ReactiveZSetCommands.zIncrBy(org.reactivestreams.Publisher<ReactiveZSetCommands.ZIncrByCommand> commands) Increment the score of element with ReactiveZSetCommands.ZIncrByCommand.getValue() in sorted set by ReactiveZSetCommands.ZIncrByCommand.getIncrement().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZInterStoreCommand,Long>>	ReactiveZSetCommands.zInterStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZInterStoreCommand> commands) Intersect sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRankCommand,Long>>	ReactiveZSetCommands.zRank(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRankCommand> commands) Determine the index of element with value in a sorted set when scored by ReactiveZSetCommands.ZRankCommand.getDirection().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemCommand,Long>>	ReactiveZSetCommands.zRem(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemCommand> commands) Remove ReactiveZSetCommands.ZRemCommand.getValues() from sorted set.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByRankCommand,Long>>	ReactiveZSetCommands.zRemRangeByRank(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByRankCommand> commands) Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByScoreCommand,Long>>	ReactiveZSetCommands.zRemRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByScoreCommand> commands) Remove elements in Range from sorted set with ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZScoreCommand,Double>>	ReactiveZSetCommands.zScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZScoreCommand> commands) Get the score of element with ReactiveZSetCommands.ZScoreCommand.getValue() from sorted set with key ReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZUnionStoreCommand,Long>>	ReactiveZSetCommands.zUnionStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZUnionStoreCommand> commands) Union sorted sets by applying aggregateFunction and store result in destination destinationKey and apply weights to individual sets.

Uses of ReactiveRedisConnection.NumericResponse in org.springframework.data.redis.connection.lettuce

Methods in org.springframework.data.redis.connection.lettuce that return types with arguments of type ReactiveRedisConnection.NumericResponse

Modifier and Type	Method and Description
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.AppendCommand,Long>>	LettuceReactiveStringCommands.append(org.reactivestreams.Publisher<ReactiveStringCommands.AppendCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitCountCommand,Long>>	LettuceReactiveStringCommands.bitCount(org.reactivestreams.Publisher<ReactiveStringCommands.BitCountCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitOpCommand,Long>>	LettuceReactiveStringCommands.bitOp(org.reactivestreams.Publisher<ReactiveStringCommands.BitOpCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitOpCommand,Long>>	LettuceReactiveClusterStringCommands.bitOp(org.reactivestreams.Publisher<ReactiveStringCommands.BitOpCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	LettuceReactiveNumberCommands.decr(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.DecrByCommand<T>,T>>	LettuceReactiveNumberCommands.decrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.DecrByCommand<T>> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	LettuceReactiveKeyCommands.del(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveGeoCommands.GeoAddCommand,Long>>	LettuceReactiveGeoCommands.geoAdd(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoAddCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHashCommands.HDelCommand,Long>>	LettuceReactiveHashCommands.hDel(org.reactivestreams.Publisher<ReactiveHashCommands.HDelCommand> commands)
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.HIncrByCommand<T>,T>>	LettuceReactiveNumberCommands.hIncrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.HIncrByCommand<T>> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	LettuceReactiveHashCommands.hLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	LettuceReactiveNumberCommands.incr(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.IncrByCommand<T>,T>>	LettuceReactiveNumberCommands.incrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.IncrByCommand<T>> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LInsertCommand,Long>>	LettuceReactiveListCommands.lInsert(org.reactivestreams.Publisher<ReactiveListCommands.LInsertCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	LettuceReactiveListCommands.lLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,Long>>	LettuceReactiveListCommands.lRem(org.reactivestreams.Publisher<ReactiveListCommands.LRemCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<List<ByteBuffer>,Long>>	LettuceReactiveKeyCommands.mDel(org.reactivestreams.Publisher<List<ByteBuffer>> keysCollection)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfAddCommand,Long>>	LettuceReactiveHyperLogLogCommands.pfAdd(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfAddCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfCountCommand,Long>>	LettuceReactiveHyperLogLogCommands.pfCount(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfCountCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveHyperLogLogCommands.PfCountCommand,Long>>	LettuceReactiveClusterHyperLogLogCommands.pfCount(org.reactivestreams.Publisher<ReactiveHyperLogLogCommands.PfCountCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.PushCommand,Long>>	LettuceReactiveListCommands.push(org.reactivestreams.Publisher<ReactiveListCommands.PushCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,Long>>	LettuceReactiveSetCommands.sAdd(org.reactivestreams.Publisher<ReactiveSetCommands.SAddCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	LettuceReactiveSetCommands.sCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,Long>>	LettuceReactiveSetCommands.sDiffStore(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffStoreCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,Long>>	LettuceReactiveClusterSetCommands.sDiffStore(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffStoreCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.SetRangeCommand,Long>>	LettuceReactiveStringCommands.setRange(org.reactivestreams.Publisher<ReactiveStringCommands.SetRangeCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,Long>>	LettuceReactiveSetCommands.sInterStore(org.reactivestreams.Publisher<ReactiveSetCommands.SInterStoreCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,Long>>	LettuceReactiveClusterSetCommands.sInterStore(org.reactivestreams.Publisher<ReactiveSetCommands.SInterStoreCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,Long>>	LettuceReactiveSetCommands.sRem(org.reactivestreams.Publisher<ReactiveSetCommands.SRemCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	LettuceReactiveStringCommands.strLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,Long>>	LettuceReactiveSetCommands.sUnionStore(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionStoreCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,Long>>	LettuceReactiveClusterSetCommands.sUnionStore(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionStoreCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZAddCommand,Number>>	LettuceReactiveZSetCommands.zAdd(org.reactivestreams.Publisher<ReactiveZSetCommands.ZAddCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	LettuceReactiveZSetCommands.zCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZCountCommand,Long>>	LettuceReactiveZSetCommands.zCount(org.reactivestreams.Publisher<ReactiveZSetCommands.ZCountCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZIncrByCommand,Double>>	LettuceReactiveZSetCommands.zIncrBy(org.reactivestreams.Publisher<ReactiveZSetCommands.ZIncrByCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZInterStoreCommand,Long>>	LettuceReactiveZSetCommands.zInterStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZInterStoreCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZInterStoreCommand,Long>>	LettuceReactiveClusterZSetCommands.zInterStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZInterStoreCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRankCommand,Long>>	LettuceReactiveZSetCommands.zRank(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRankCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemCommand,Long>>	LettuceReactiveZSetCommands.zRem(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByRankCommand,Long>>	LettuceReactiveZSetCommands.zRemRangeByRank(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByRankCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZRemRangeByScoreCommand,Long>>	LettuceReactiveZSetCommands.zRemRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRemRangeByScoreCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZScoreCommand,Double>>	LettuceReactiveZSetCommands.zScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZScoreCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZUnionStoreCommand,Long>>	LettuceReactiveZSetCommands.zUnionStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZUnionStoreCommand> commands)
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveZSetCommands.ZUnionStoreCommand,Long>>	LettuceReactiveClusterZSetCommands.zUnionStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZUnionStoreCommand> commands)