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

Packages that use ReactiveRedisConnection.CommandResponse

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

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

Subclasses of ReactiveRedisConnection.CommandResponse in org.springframework.data.redis.connection

Modifier and Type	Class	Description
static class	ReactiveListCommands.PopResponse	Result for ReactiveListCommands.PopCommand/ReactiveListCommands.BPopCommand.
static class	ReactiveRedisConnection.AbsentByteBufferResponse<I>	ReactiveRedisConnection.CommandResponse implementation for ByteBuffer responses for absent keys.
static class	ReactiveRedisConnection.BooleanResponse<I>	ReactiveRedisConnection.CommandResponse implementation for Boolean responses.
static class	ReactiveRedisConnection.ByteBufferResponse<I>	ReactiveRedisConnection.CommandResponse implementation for ByteBuffer responses.
static class	ReactiveRedisConnection.MultiValueResponse<I,O>	ReactiveRedisConnection.CommandResponse implementation for List responses.
static class	ReactiveRedisConnection.NumericResponse<I,O extends Number>	ReactiveRedisConnection.CommandResponse implementation for numeric responses.

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

Modifier and Type	Method	Description
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.BZPopCommand,reactor.core.publisher.Flux<Tuple>>>	ReactiveZSetCommands.bZPop(org.reactivestreams.Publisher<ReactiveZSetCommands.BZPopCommand> commands)	Remove and return elements from sorted set at keyCommand#getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoDistCommand,Distance>>	ReactiveGeoCommands.geoDist(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoDistCommand> commands)	Get the Distance between from and to.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>>	ReactiveGeoCommands.geoRadius(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusCommand> commands)	Get the members within the boundaries of a given Circle applying given parameters.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoRadiusByMemberCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>>	ReactiveGeoCommands.geoRadiusByMember(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoRadiusByMemberCommand> commands)	Get the members within given Distance from member applying given parameters.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveGeoCommands.GeoSearchCommand,reactor.core.publisher.Flux<GeoResult<RedisGeoCommands.GeoLocation<ByteBuffer>>>>>	ReactiveGeoCommands.geoSearch(org.reactivestreams.Publisher<ReactiveGeoCommands.GeoSearchCommand> commands)	Get the members within given GeoShape from GeoReference applying given parameters.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>>>>	ReactiveHashCommands.hGetAll(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get entire hash stored at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveHashCommands.hKeys(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get key set (fields) of hash at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveHashCommands.hRandField(org.reactivestreams.Publisher<ReactiveHashCommands.HRandFieldCommand> commands)	Get random fields of hash at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveHashCommands.HRandFieldCommand,reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>>>>	ReactiveHashCommands.hRandFieldWithValues(org.reactivestreams.Publisher<ReactiveHashCommands.HRandFieldCommand> commands)	Get random fields along their values of hash at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<Map.Entry<ByteBuffer,ByteBuffer>>>>	ReactiveHashCommands.hScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands)	Use a Flux to iterate over entries in the hash at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveHashCommands.hVals(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get entry set (values) of hash at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.RangeCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveListCommands.lRange(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands)	Get elements in ReactiveRedisConnection.RangeCommand.getRange() from list at ReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveListCommands.PopCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveListCommands.popList(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands)	Removes and returns last element in list stored at ReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	ReactiveStreamCommands.read(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands)	Read records from one or more StreamOffsets.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SDiffCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveSetCommands.sDiff(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffCommand> commands)	Returns the diff of the members of all given sets at ReactiveSetCommands.SInterCommand.getKeys().
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SInterCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveSetCommands.sInter(org.reactivestreams.Publisher<ReactiveSetCommands.SInterCommand> commands)	Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveSetCommands.sMembers(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get all elements of set at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SRandMembersCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveSetCommands.sRandMember(org.reactivestreams.Publisher<ReactiveSetCommands.SRandMembersCommand> commands)	Get ReactiveSetCommands.SRandMembersCommand.getCount() random elements from set at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveSetCommands.sScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands)	Use a Flux to iterate over members in the set at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveSetCommands.SUnionCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveSetCommands.sUnion(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionCommand> commands)	Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,DataType>>	ReactiveKeyCommands.type(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys)	Determine the type stored at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,RecordId>>	ReactiveStreamCommands.xAdd(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands)	Add stream record with given body to key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	ReactiveStreamCommands.xClaim(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)	Change the ownership of a pending message to the given new consumer.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<RecordId>>>	ReactiveStreamCommands.xClaimJustId(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)	Change the ownership of a pending message to the given new consumer without increasing the delivered count.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.DeleteCommand,Long>>	ReactiveStreamCommands.xDel(org.reactivestreams.Publisher<ReactiveStreamCommands.DeleteCommand> commands)	Removes the specified entries from the stream.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,String>>	ReactiveStreamCommands.xGroup(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands)	Execute the given ReactiveStreamCommands.GroupCommand to create, destroy,... groups.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,StreamInfo.XInfoStream>>	ReactiveStreamCommands.xInfo(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)	Obtain general information about the stream stored at the specified key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoConsumer>>>	ReactiveStreamCommands.xInfoConsumers(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)	Obtain information about every consumer in a specific consumer group for the stream stored at the specified key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoGroup>>>	ReactiveStreamCommands.xInfoGroups(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)	Obtain general information about the stream stored at the specified key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessages>>	ReactiveStreamCommands.xPending(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands)	Obtain detailed information about pending messages applying given options.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessagesSummary>>	ReactiveStreamCommands.xPendingSummary(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands)	Obtain the PendingMessagesSummary for a given consumer group.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	ReactiveStreamCommands.xRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)	Read records from a stream within a specific Range applying a Limit.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	ReactiveStreamCommands.xRevRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)	Read records from a stream within a specific Range applying a Limit in reverse order.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveZSetCommands.zDiff(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands)	Diff sorted sets.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZDiffCommand,reactor.core.publisher.Flux<Tuple>>>	ReactiveZSetCommands.zDiffWithScores(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZDiffCommand> commands)	Diff sorted sets.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveZSetCommands.zInter(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,reactor.core.publisher.Flux<Tuple>>>	ReactiveZSetCommands.zInterWithScores(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Intersect sorted sets by applying aggregateFunction and apply weights to individual sets.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZPopCommand,reactor.core.publisher.Flux<Tuple>>>	ReactiveZSetCommands.zPop(org.reactivestreams.Publisher<ReactiveZSetCommands.ZPopCommand> commands)	Remove and return elements from sorted set at keyCommand#getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveZSetCommands.zRandMember(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands)	Get random elements from sorted set at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRandMemberCommand,reactor.core.publisher.Flux<Tuple>>>	ReactiveZSetCommands.zRandMemberWithScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRandMemberCommand> commands)	Get random elements from sorted set at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeCommand,reactor.core.publisher.Flux<Tuple>>>	ReactiveZSetCommands.zRange(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeCommand> commands)	Get set of Tuples in range from sorted set.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByLexCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveZSetCommands.zRangeByLex(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByLexCommand> commands)	Get all elements in Range from the sorted set at key in lexicographical ordering.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeByScoreCommand,reactor.core.publisher.Flux<Tuple>>>	ReactiveZSetCommands.zRangeByScore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeByScoreCommand> commands)	Get Tuples in range from sorted set.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZRangeStoreCommand,reactor.core.publisher.Mono<Long>>>	ReactiveZSetCommands.zRangeStore(org.reactivestreams.Publisher<ReactiveZSetCommands.ZRangeStoreCommand> commands)	Get set of Tuples in range from sorted set.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.KeyCommand,reactor.core.publisher.Flux<Tuple>>>	ReactiveZSetCommands.zScan(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyScanCommand> commands)	Use a Flux to iterate over members in the sorted set at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,reactor.core.publisher.Flux<ByteBuffer>>>	ReactiveZSetCommands.zUnion(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Union sorted sets by applying aggregateFunction and apply weights to individual sets.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveZSetCommands.ZAggregateCommand,reactor.core.publisher.Flux<Tuple>>>	ReactiveZSetCommands.zUnionWithScores(org.reactivestreams.Publisher<? extends ReactiveZSetCommands.ZAggregateCommand> commands)	Union sorted sets by applying aggregateFunction and apply weights to individual sets.