reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BRPopLPushCommand>> |
ReactiveListCommands.bRPopLPush(org.reactivestreams.Publisher<ReactiveListCommands.BRPopLPushCommand> commands)
|
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>> |
ReactiveStringCommands.get(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> keys)
Get elements one by one.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.RangeCommand>> |
ReactiveStringCommands.getRange(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands)
Get a substring of value of key between begin and end.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveStringCommands.SetCommand>> |
ReactiveStringCommands.getSet(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)
Set value for key and return the existing value one by one.
|
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LIndexCommand>> |
ReactiveListCommands.lIndex(org.reactivestreams.Publisher<ReactiveListCommands.LIndexCommand> commands)
|
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.PopCommand>> |
ReactiveListCommands.pop(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands)
|
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.RPopLPushCommand>> |
ReactiveListCommands.rPopLPush(org.reactivestreams.Publisher<ReactiveListCommands.RPopLPushCommand> commands)
|
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>> |
ReactiveSetCommands.sPop(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)
|