Package | Description |
---|---|
org.springframework.data.redis.connection |
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
|
Modifier and Type | Method and Description |
---|---|
ReactiveStreamCommands.RangeCommand |
ReactiveStreamCommands.RangeCommand.limit(int count)
Applies a
Limit . |
ReactiveStreamCommands.RangeCommand |
ReactiveStreamCommands.RangeCommand.limit(RedisZSetCommands.Limit limit)
Applies a
Limit . |
static ReactiveStreamCommands.RangeCommand |
ReactiveStreamCommands.RangeCommand.stream(ByteBuffer key)
Creates a new
ReactiveStreamCommands.RangeCommand given a key . |
ReactiveStreamCommands.RangeCommand |
ReactiveStreamCommands.RangeCommand.within(Range<String> range)
Applies a
Range . |
Modifier and Type | Method and Description |
---|---|
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 RedisZSetCommands.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 RedisZSetCommands.Limit in reverse order. |
Modifier and Type | Method and Description |
---|---|
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 RedisZSetCommands.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 RedisZSetCommands.Limit in reverse order. |
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.