org.springframework.data.redis.connection.lettuce

Class LettuceReactiveStringCommands

java.lang.Object

org.springframework.data.redis.connection.lettuce.LettuceReactiveStringCommands

All Implemented Interfaces:

ReactiveStringCommands

Direct Known Subclasses:

LettuceReactiveClusterStringCommands

public class LettuceReactiveStringCommands
extends Object
implements ReactiveStringCommands

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

Nested classes/interfaces inherited from interface org.springframework.data.redis.connection.ReactiveStringCommands

ReactiveStringCommands.AppendCommand, ReactiveStringCommands.BitCountCommand, ReactiveStringCommands.BitOpCommand, ReactiveStringCommands.GetBitCommand, ReactiveStringCommands.MSetCommand, ReactiveStringCommands.SetBitCommand, ReactiveStringCommands.SetCommand, ReactiveStringCommands.SetRangeCommand

Constructor Summary

Constructors

Constructor and Description
LettuceReactiveStringCommands(LettuceReactiveRedisConnection connection) Create new LettuceReactiveStringCommands.

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.AppendCommand,Long>>	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>>	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>>	bitOp(org.reactivestreams.Publisher<ReactiveStringCommands.BitOpCommand> commands) Perform bitwise operations between strings.
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>>	get(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get elements one by one.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.GetBitCommand>>	getBit(org.reactivestreams.Publisher<ReactiveStringCommands.GetBitCommand> commands) Get the bit value at offset of value at key.
protected LettuceReactiveRedisConnection	getConnection()
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.RangeCommand>>	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>>	getSet(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands) Set value for key and return the existing value one by one.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<List<ByteBuffer>,ByteBuffer>>	mGet(org.reactivestreams.Publisher<List<ByteBuffer>> keyCollections) Get multiple values at for keysets in batches.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.MSetCommand>>	mSet(org.reactivestreams.Publisher<ReactiveStringCommands.MSetCommand> commands) Set multiple keys to multiple values using key-value pairs provided in commands.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.MSetCommand>>	mSetNX(org.reactivestreams.Publisher<ReactiveStringCommands.MSetCommand> commands) Set multiple keys to multiple values using key-value pairs provided in tuples only if the provided key does not exist.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>	pSetEX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands) Set key value pairs and Expiration.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>	set(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands) Set each and every item separately by invoking ReactiveStringCommands.SetCommand.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetBitCommand>>	setBit(org.reactivestreams.Publisher<ReactiveStringCommands.SetBitCommand> commands) Sets the bit at offset in value stored at key and return the original value.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>	setEX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands) Set key value pairs and Expiration.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>>	setNX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands) Set key value pairs, only if key does not exist.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.SetRangeCommand,Long>>	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<ReactiveRedisConnection.KeyCommand,Long>>	strLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get the length of the value stored at key.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.data.redis.connection.ReactiveStringCommands

append, bitCount, bitCount, bitOp, get, getBit, getRange, getSet, mGet, mSet, mSetNX, pSetEX, set, set, setBit, setEX, setNX, setRange, strLen

Constructor Detail

LettuceReactiveStringCommands

public LettuceReactiveStringCommands(LettuceReactiveRedisConnection connection)

Create new LettuceReactiveStringCommands.

Parameters:

connection - must not be null.

Method Detail

mGet

public reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<List<ByteBuffer>,ByteBuffer>> mGet(org.reactivestreams.Publisher<List<ByteBuffer>> keyCollections)

Description copied from interface: ReactiveStringCommands

Get multiple values at for keysets in batches.

Specified by:

mGet in interface ReactiveStringCommands

Parameters:

keyCollections - must not be null.

Returns:

set

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>> set(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)

Description copied from interface: ReactiveStringCommands

Set each and every item separately by invoking ReactiveStringCommands.SetCommand.

Specified by:

set in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.BooleanResponse holding the ReactiveStringCommands.SetCommand along with the command result.

getSet

public reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveStringCommands.SetCommand>> getSet(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)

Description copied from interface: ReactiveStringCommands

Set value for key and return the existing value one by one.

Specified by:

getSet in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.ByteBufferResponse holding the ReactiveStringCommands.SetCommand along with the previously existing value.

get

public reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>> get(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Description copied from interface: ReactiveStringCommands

Get elements one by one.

Specified by:

get in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

Flux of ReactiveRedisConnection.ByteBufferResponse holding the key to get along with the value retrieved.

setNX

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>> setNX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)

Description copied from interface: ReactiveStringCommands

Set key value pairs, only if key does not exist.

Specified by:

setNX in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

setEX

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>> setEX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)

Description copied from interface: ReactiveStringCommands

Set key value pairs and Expiration.

Specified by:

setEX in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

pSetEX

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetCommand>> pSetEX(org.reactivestreams.Publisher<ReactiveStringCommands.SetCommand> commands)

Description copied from interface: ReactiveStringCommands

Set key value pairs and Expiration.

Specified by:

pSetEX in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

mSet

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.MSetCommand>> mSet(org.reactivestreams.Publisher<ReactiveStringCommands.MSetCommand> commands)

Description copied from interface: ReactiveStringCommands

Set multiple keys to multiple values using key-value pairs provided in commands.

Specified by:

mSet in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

mSetNX

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.MSetCommand>> mSetNX(org.reactivestreams.Publisher<ReactiveStringCommands.MSetCommand> commands)

Description copied from interface: ReactiveStringCommands

Set multiple keys to multiple values using key-value pairs provided in tuples only if the provided key does not exist.

Specified by:

mSetNX in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

append

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.AppendCommand,Long>> append(org.reactivestreams.Publisher<ReactiveStringCommands.AppendCommand> commands)

Description copied from interface: ReactiveStringCommands

Append a ReactiveStringCommands.AppendCommand.getValue() to the ReactiveRedisConnection.KeyCommand.getKey().

Specified by:

append in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

getRange

public reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.RangeCommand>> getRange(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands)

Description copied from interface: ReactiveStringCommands

Get a substring of value of key between begin and end.

Specified by:

getRange in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

setRange

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.SetRangeCommand,Long>> setRange(org.reactivestreams.Publisher<ReactiveStringCommands.SetRangeCommand> commands)

Description copied from interface: ReactiveStringCommands

Overwrite parts of ReactiveRedisConnection.KeyCommand.key starting at the specified offset with given ReactiveStringCommands.SetRangeCommand.value.

Specified by:

setRange in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

getBit

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.GetBitCommand>> getBit(org.reactivestreams.Publisher<ReactiveStringCommands.GetBitCommand> commands)

Description copied from interface: ReactiveStringCommands

Get the bit value at offset of value at key.

Specified by:

getBit in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

setBit

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveStringCommands.SetBitCommand>> setBit(org.reactivestreams.Publisher<ReactiveStringCommands.SetBitCommand> commands)

Description copied from interface: ReactiveStringCommands

Sets the bit at offset in value stored at key and return the original value.

Specified by:

setBit in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

bitCount

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitCountCommand,Long>> bitCount(org.reactivestreams.Publisher<ReactiveStringCommands.BitCountCommand> commands)

Description copied from interface: ReactiveStringCommands

Count the number of set bits (population counting) of value stored at key between begin and end.

Specified by:

bitCount in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

bitOp

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStringCommands.BitOpCommand,Long>> bitOp(org.reactivestreams.Publisher<ReactiveStringCommands.BitOpCommand> commands)

Description copied from interface: ReactiveStringCommands

Perform bitwise operations between strings.

Specified by:

bitOp in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

strLen

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> strLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Description copied from interface: ReactiveStringCommands

Get the length of the value stored at key.

Specified by:

strLen in interface ReactiveStringCommands

Parameters:

commands - must not be null.

Returns:

getConnection

protected LettuceReactiveRedisConnection getConnection()