Package org.springframework.data.redis.connection

Interface ReactiveListCommands

All Known Subinterfaces:

ReactiveClusterListCommands

public interface ReactiveListCommands

Redis List commands executed using reactive infrastructure.

Since:

2.0

Author:

Christoph Strobl, Mark Paluch, dengliming

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	ReactiveListCommands.BLMoveCommand	BLMOVE command parameters.
static class	ReactiveListCommands.BPopCommand
static class	ReactiveListCommands.BRPopLPushCommand	BRPOPLPUSH command parameters.
static enum	ReactiveListCommands.Direction
static class	ReactiveListCommands.LIndexCommand	LINDEX command parameters.
static class	ReactiveListCommands.LInsertCommand	LINSERT command parameters.
static class	ReactiveListCommands.LMoveCommand	LMOVE command parameters.
static class	ReactiveListCommands.LPosCommand	LPOS command parameters.
static class	ReactiveListCommands.LRemCommand	LREM command parameters.
static class	ReactiveListCommands.LSetCommand	LSET command parameters.
static class	ReactiveListCommands.PopCommand	LPOP/RPOP command parameters.
static class	ReactiveListCommands.PopResponse	Result for ReactiveListCommands.PopCommand/ReactiveListCommands.BPopCommand.
static class	ReactiveListCommands.PopResult	Result for ReactiveListCommands.PopCommand/ReactiveListCommands.BPopCommand.
static class	ReactiveListCommands.PushCommand	LPUSH/RPUSH command parameters.
static class	ReactiveListCommands.RPopLPushCommand	RPOPLPUSH command parameters.

Method Summary

Modifier and Type	Method	Description
default Mono<ByteBuffer>	bLMove(ByteBuffer sourceKey, ByteBuffer destinationKey, ReactiveListCommands.Direction from, ReactiveListCommands.Direction to, Duration timeout)	Atomically returns and removes the first/last element (head/tail depending on the from argument) of the list stored at sourceKey, and pushes the element at the first/last element (head/tail depending on the to argument) of the list stored at destinationKey.
Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BLMoveCommand>>	bLMove(Publisher<ReactiveListCommands.BLMoveCommand> commands)	Atomically returns and removes the first/last element (head/tail depending on the from argument) of the list stored at sourceKey, and pushes the element at the first/last element (head/tail depending on the to argument) of the list stored at destinationKey.
default Mono<ReactiveListCommands.PopResult>	blPop(List<ByteBuffer> keys, Duration timeout)	Removes and returns first element from lists stored at keys.
Flux<ReactiveListCommands.PopResponse>	bPop(Publisher<ReactiveListCommands.BPopCommand> commands)	Removes and returns the top ReactiveListCommands.BPopCommand.getDirection() element from lists stored at ReactiveListCommands.BPopCommand.getKeys(). Blocks connection until element available or ReactiveListCommands.BPopCommand.getTimeout() reached.
default Mono<ReactiveListCommands.PopResult>	brPop(List<ByteBuffer> keys, Duration timeout)	Removes and returns last element from lists stored at keys.
default Mono<ByteBuffer>	bRPopLPush(ByteBuffer source, ByteBuffer destination, Duration timeout)	Remove the last element from list at source, append it to destination and return its value.
Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BRPopLPushCommand>>	bRPopLPush(Publisher<ReactiveListCommands.BRPopLPushCommand> commands)	Remove the last element from list at ReactiveRedisConnection.KeyCommand.getKey(), append it to ReactiveListCommands.BRPopLPushCommand.getDestination() and return its value.
default Mono<ByteBuffer>	lIndex(ByteBuffer key, long index)	Get element at index form list at key.
Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LIndexCommand>>	lIndex(Publisher<ReactiveListCommands.LIndexCommand> commands)	Get element at ReactiveListCommands.LIndexCommand.getIndex() form list at ReactiveRedisConnection.KeyCommand.getKey().
default Mono<Long>	lInsert(ByteBuffer key, RedisListCommands.Position position, ByteBuffer pivot, ByteBuffer value)	Insert value RedisListCommands.Position.BEFORE or RedisListCommands.Position.AFTER existing pivot for key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LInsertCommand,Long>>	lInsert(Publisher<ReactiveListCommands.LInsertCommand> commands)	Insert ReactiveListCommands.LInsertCommand.getValue() RedisListCommands.Position.BEFORE or RedisListCommands.Position.AFTER existing ReactiveListCommands.LInsertCommand.getPivot() for ReactiveRedisConnection.KeyCommand.getKey()
default Mono<Long>	lLen(ByteBuffer key)	Get the size of list stored at key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	lLen(Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get the size of list stored at ReactiveRedisConnection.KeyCommand.getKey()
default Mono<ByteBuffer>	lMove(ByteBuffer sourceKey, ByteBuffer destinationKey, ReactiveListCommands.Direction from, ReactiveListCommands.Direction to)	Atomically returns and removes the first/last element (head/tail depending on the from argument) of the list stored at sourceKey, and pushes the element at the first/last element (head/tail depending on the to argument) of the list stored at destinationKey.
Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LMoveCommand>>	lMove(Publisher<? extends ReactiveListCommands.LMoveCommand> commands)	Atomically returns and removes the first/last element (head/tail depending on the from argument) of the list stored at sourceKey, and pushes the element at the first/last element (head/tail depending on the to argument) of the list stored at destinationKey.
default Mono<ByteBuffer>	lPop(ByteBuffer key)	Removes and returns first element in list stored at key.
default Flux<ByteBuffer>	lPop(ByteBuffer key, long count)	Removes and returns first count elements in list stored at key.
default Mono<Long>	lPos(ByteBuffer key, ByteBuffer element)	Get first index of the element from list at key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LPosCommand,Long>>	lPos(Publisher<ReactiveListCommands.LPosCommand> commands)	Get indices of the element from list at ReactiveRedisConnection.KeyCommand.getKey().
default Flux<Long>	lPos(ReactiveListCommands.LPosCommand command)	Get indices of the element from list at ReactiveRedisConnection.KeyCommand.getKey().
default Mono<Long>	lPush(ByteBuffer key, List<ByteBuffer> values)	Prepend values to key.
default Mono<Long>	lPushX(ByteBuffer key, ByteBuffer value)	Prepend value to key if key already exists.
default Flux<ByteBuffer>	lRange(ByteBuffer key, long start, long end)	Get elements between start and end from list at key.
Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.RangeCommand,Flux<ByteBuffer>>>	lRange(Publisher<ReactiveRedisConnection.RangeCommand> commands)	Get elements in ReactiveRedisConnection.RangeCommand.getRange() from list at ReactiveRedisConnection.KeyCommand.getKey()
default Mono<Long>	lRem(ByteBuffer key, Long count, ByteBuffer value)	Removes the first count occurrences of value from the list stored at key.
default Mono<Long>	lRem(ByteBuffer key, ByteBuffer value)	Removes all occurrences of value from the list stored at key.
Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,Long>>	lRem(Publisher<ReactiveListCommands.LRemCommand> commands)	Removes the ReactiveListCommands.LRemCommand.getCount() occurrences of ReactiveListCommands.LRemCommand.getValue() from the list stored at ReactiveRedisConnection.KeyCommand.getKey().
default Mono<Boolean>	lSet(ByteBuffer key, long index, ByteBuffer value)	Set the value list element at index.
Flux<ReactiveRedisConnection.BooleanResponse<ReactiveListCommands.LSetCommand>>	lSet(Publisher<ReactiveListCommands.LSetCommand> commands)	Set the ReactiveListCommands.LSetCommand.getValue() list element at ReactiveRedisConnection.KeyCommand.getKey().
default Mono<Boolean>	lTrim(ByteBuffer key, long start, long end)	Trim list at key to elements between start and end.
Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.RangeCommand>>	lTrim(Publisher<ReactiveRedisConnection.RangeCommand> commands)	Trim list at ReactiveRedisConnection.KeyCommand.getKey() to elements within ReactiveRedisConnection.RangeCommand.getRange().
Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.PopCommand>>	pop(Publisher<ReactiveListCommands.PopCommand> commands)	Removes and returns last element in list stored at ReactiveRedisConnection.KeyCommand.getKey()
Flux<ReactiveRedisConnection.CommandResponse<ReactiveListCommands.PopCommand,Flux<ByteBuffer>>>	popList(Publisher<ReactiveListCommands.PopCommand> commands)	Removes and returns last element in list stored at ReactiveRedisConnection.KeyCommand.getKey()
Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.PushCommand,Long>>	push(Publisher<ReactiveListCommands.PushCommand> commands)	Prepend ReactiveListCommands.PushCommand.getValues() to ReactiveRedisConnection.KeyCommand.getKey().
default Mono<ByteBuffer>	rPop(ByteBuffer key)	Removes and returns last element in list stored at key.
default Flux<ByteBuffer>	rPop(ByteBuffer key, long count)	Removes and returns last count elements in list stored at key.
default Mono<ByteBuffer>	rPopLPush(ByteBuffer source, ByteBuffer destination)	Remove the last element from list at source, append it to destination and return its value.
Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.RPopLPushCommand>>	rPopLPush(Publisher<ReactiveListCommands.RPopLPushCommand> commands)	Remove the last element from list at ReactiveRedisConnection.KeyCommand.getKey(), append it to ReactiveListCommands.RPopLPushCommand.getDestination() and return its value.
default Mono<Long>	rPush(ByteBuffer key, List<ByteBuffer> values)	Append values to key.
default Mono<Long>	rPushX(ByteBuffer key, ByteBuffer value)	Append values to key only if key already exists.

Method Details

rPush

default Mono<Long> rPush(ByteBuffer key,
 List<ByteBuffer> values)

Append values to key.

Parameters:

key - must not be null.

values - must not be null.

Returns:

See Also:

• Redis Documentation: RPUSH

rPushX

default Mono<Long> rPushX(ByteBuffer key,
 ByteBuffer value)

Append values to key only if key already exists.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: RPUSHX

lPush

default Mono<Long> lPush(ByteBuffer key,
 List<ByteBuffer> values)

Prepend values to key.

Parameters:

key - must not be null.

values - must not be null.

Returns:

See Also:

• Redis Documentation: LPUSH

lPushX

default Mono<Long> lPushX(ByteBuffer key,
 ByteBuffer value)

Prepend value to key if key already exists.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: LPUSHX

push

Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.PushCommand,Long>> push(Publisher<ReactiveListCommands.PushCommand> commands)

Prepend ReactiveListCommands.PushCommand.getValues() to ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: LPUSH
• Redis Documentation: RPUSH

lLen

default Mono<Long> lLen(ByteBuffer key)

Get the size of list stored at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: LLEN

lLen

Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> lLen(Publisher<ReactiveRedisConnection.KeyCommand> commands)

Get the size of list stored at ReactiveRedisConnection.KeyCommand.getKey()

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: LLEN

lRange

default Flux<ByteBuffer> lRange(ByteBuffer key,
 long start,
 long end)

Get elements between start and end from list at key.

Parameters:

key - must not be null.

start -

end -

Returns:

See Also:

• Redis Documentation: LRANGE

lRange

Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.RangeCommand,Flux<ByteBuffer>>> lRange(Publisher<ReactiveRedisConnection.RangeCommand> commands)

Get elements in ReactiveRedisConnection.RangeCommand.getRange() from list at ReactiveRedisConnection.KeyCommand.getKey()

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: LRANGE

lTrim

default Mono<Boolean> lTrim(ByteBuffer key,
 long start,
 long end)

Trim list at key to elements between start and end.

Parameters:

key - must not be null.

start -

end -

Returns:

See Also:

• Redis Documentation: LTRIM

lTrim

Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.RangeCommand>> lTrim(Publisher<ReactiveRedisConnection.RangeCommand> commands)

Trim list at ReactiveRedisConnection.KeyCommand.getKey() to elements within ReactiveRedisConnection.RangeCommand.getRange().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: LTRIM

lPos

default Mono<Long> lPos(ByteBuffer key,
 ByteBuffer element)

Get first index of the element from list at key.

Parameters:

key - must not be null.

element -

Returns:

a Mono emitting the elements index.

Since:

2.4

See Also:

• Redis Documentation: LINDEX

lPos

default Flux<Long> lPos(ReactiveListCommands.LPosCommand command)

Get indices of the element from list at ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

command - must not be null.

Returns:

a Flux emitting the elements indices one by one.

Since:

2.4

See Also:

• Redis Documentation: LINDEX

lPos

Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LPosCommand,Long>> lPos(Publisher<ReactiveListCommands.LPosCommand> commands)

Get indices of the element from list at ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

a Flux emitting the elements indices one by one.

Since:

2.4

See Also:

• Redis Documentation: LINDEX

lIndex

default Mono<ByteBuffer> lIndex(ByteBuffer key,
 long index)

Get element at index form list at key.

Parameters:

key - must not be null.

index -

Returns:

See Also:

• Redis Documentation: LINDEX

lIndex

Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LIndexCommand>> lIndex(Publisher<ReactiveListCommands.LIndexCommand> commands)

Get element at ReactiveListCommands.LIndexCommand.getIndex() form list at ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: LINDEX

lInsert

default Mono<Long> lInsert(ByteBuffer key,
 RedisListCommands.Position position,
 ByteBuffer pivot,
 ByteBuffer value)

Insert value RedisListCommands.Position.BEFORE or RedisListCommands.Position.AFTER existing pivot for key.

Parameters:

key - must not be null.

position - must not be null.

pivot - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: LINSERT

lInsert

Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LInsertCommand,Long>> lInsert(Publisher<ReactiveListCommands.LInsertCommand> commands)

Insert ReactiveListCommands.LInsertCommand.getValue() RedisListCommands.Position.BEFORE or RedisListCommands.Position.AFTER existing ReactiveListCommands.LInsertCommand.getPivot() for ReactiveRedisConnection.KeyCommand.getKey()

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: LINSERT

lMove

default Mono<ByteBuffer> lMove(ByteBuffer sourceKey,
 ByteBuffer destinationKey,
 ReactiveListCommands.Direction from,
 ReactiveListCommands.Direction to)

Atomically returns and removes the first/last element (head/tail depending on the from argument) of the list stored at sourceKey, and pushes the element at the first/last element (head/tail depending on the to argument) of the list stored at destinationKey.

Parameters:

sourceKey - must not be null.

destinationKey - must not be null.

from - must not be null.

to - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: LMOVE

lMove

Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LMoveCommand>> lMove(Publisher<? extends ReactiveListCommands.LMoveCommand> commands)

Atomically returns and removes the first/last element (head/tail depending on the from argument) of the list stored at sourceKey, and pushes the element at the first/last element (head/tail depending on the to argument) of the list stored at destinationKey.

Parameters:

commands - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: LMOVE

bLMove

default Mono<ByteBuffer> bLMove(ByteBuffer sourceKey,
 ByteBuffer destinationKey,
 ReactiveListCommands.Direction from,
 ReactiveListCommands.Direction to,
 Duration timeout)

Atomically returns and removes the first/last element (head/tail depending on the from argument) of the list stored at sourceKey, and pushes the element at the first/last element (head/tail depending on the to argument) of the list stored at destinationKey.

Parameters:

sourceKey - must not be null.

destinationKey - must not be null.

from - must not be null.

to - must not be null.

timeout -

Returns:

Since:

2.6

See Also:

• Redis Documentation: BLMOVE

bLMove

Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BLMoveCommand>> bLMove(Publisher<ReactiveListCommands.BLMoveCommand> commands)

Atomically returns and removes the first/last element (head/tail depending on the from argument) of the list stored at sourceKey, and pushes the element at the first/last element (head/tail depending on the to argument) of the list stored at destinationKey.

Blocks connection until element available or timeout reached.

Parameters:

commands - must not be null.

Returns:

Since:

2.6

See Also:

• Redis Documentation: BLMOVE

lSet

default Mono<Boolean> lSet(ByteBuffer key,
 long index,
 ByteBuffer value)

Set the value list element at index.

Parameters:

key - must not be null.

index -

value - must not be null.

Returns:

See Also:

• Redis Documentation: LSET

lSet

Flux<ReactiveRedisConnection.BooleanResponse<ReactiveListCommands.LSetCommand>> lSet(Publisher<ReactiveListCommands.LSetCommand> commands)

Set the ReactiveListCommands.LSetCommand.getValue() list element at ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands -

Returns:

See Also:

• Redis Documentation: LSET

lRem

default Mono<Long> lRem(ByteBuffer key,
 ByteBuffer value)

Removes all occurrences of value from the list stored at key.

Parameters:

key - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: LREM

lRem

default Mono<Long> lRem(ByteBuffer key,
 Long count,
 ByteBuffer value)

Removes the first count occurrences of value from the list stored at key.

Parameters:

key - must not be null.

count - must not be null.

value - must not be null.

Returns:

See Also:

• Redis Documentation: LREM

lRem

Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,Long>> lRem(Publisher<ReactiveListCommands.LRemCommand> commands)

Removes the ReactiveListCommands.LRemCommand.getCount() occurrences of ReactiveListCommands.LRemCommand.getValue() from the list stored at ReactiveRedisConnection.KeyCommand.getKey().

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: LREM

lPop

default Mono<ByteBuffer> lPop(ByteBuffer key)

Removes and returns first element in list stored at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: LPOP

lPop

default Flux<ByteBuffer> lPop(ByteBuffer key,
 long count)

Removes and returns first count elements in list stored at key.

Parameters:

key - must not be null.

count -

Returns:

Since:

2.6

See Also:

• Redis Documentation: LPOP

rPop

default Mono<ByteBuffer> rPop(ByteBuffer key)

Removes and returns last element in list stored at key.

Parameters:

key - must not be null.

Returns:

See Also:

• Redis Documentation: RPOP

rPop

default Flux<ByteBuffer> rPop(ByteBuffer key,
 long count)

Removes and returns last count elements in list stored at key.

Parameters:

key - must not be null.

count -

Returns:

Since:

2.6

See Also:

• Redis Documentation: RPOP

pop

Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.PopCommand>> pop(Publisher<ReactiveListCommands.PopCommand> commands)

Removes and returns last element in list stored at ReactiveRedisConnection.KeyCommand.getKey()

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: LPOP
• Redis Documentation: RPOP

popList

Flux<ReactiveRedisConnection.CommandResponse<ReactiveListCommands.PopCommand,Flux<ByteBuffer>>> popList(Publisher<ReactiveListCommands.PopCommand> commands)

Removes and returns last element in list stored at ReactiveRedisConnection.KeyCommand.getKey()

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: LPOP
• Redis Documentation: RPOP

blPop

default Mono<ReactiveListCommands.PopResult> blPop(List<ByteBuffer> keys,
 Duration timeout)

Removes and returns first element from lists stored at keys.
Blocks connection until element available or timeout reached.

Parameters:

keys - must not be null.

timeout - must not be null.

Returns:

See Also:

• Redis Documentation: BLPOP

brPop

default Mono<ReactiveListCommands.PopResult> brPop(List<ByteBuffer> keys,
 Duration timeout)

Removes and returns last element from lists stored at keys.
Blocks connection until element available or timeout reached.

Parameters:

keys - must not be null.

timeout - must not be null.

Returns:

See Also:

• Redis Documentation: BRPOP

bPop

Flux<ReactiveListCommands.PopResponse> bPop(Publisher<ReactiveListCommands.BPopCommand> commands)

Removes and returns the top ReactiveListCommands.BPopCommand.getDirection() element from lists stored at ReactiveListCommands.BPopCommand.getKeys().
Blocks connection until element available or ReactiveListCommands.BPopCommand.getTimeout() reached.

Parameters:

commands -

Returns:

See Also:

• Redis Documentation: BLPOP
• Redis Documentation: BRPOP

rPopLPush

default Mono<ByteBuffer> rPopLPush(ByteBuffer source,
 ByteBuffer destination)

Remove the last element from list at source, append it to destination and return its value.

Parameters:

source - must not be null.

destination - must not be null.

Returns:

See Also:

• Redis Documentation: RPOPLPUSH

rPopLPush

Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.RPopLPushCommand>> rPopLPush(Publisher<ReactiveListCommands.RPopLPushCommand> commands)

Remove the last element from list at ReactiveRedisConnection.KeyCommand.getKey(), append it to ReactiveListCommands.RPopLPushCommand.getDestination() and return its value.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: RPOPLPUSH

bRPopLPush

default Mono<ByteBuffer> bRPopLPush(ByteBuffer source,
 ByteBuffer destination,
 Duration timeout)

Remove the last element from list at source, append it to destination and return its value. Blocks connection until element available or timeout reached.

Parameters:

source - must not be null.

destination - must not be null.

Returns:

See Also:

• Redis Documentation: BRPOPLPUSH

bRPopLPush

Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BRPopLPushCommand>> bRPopLPush(Publisher<ReactiveListCommands.BRPopLPushCommand> commands)

Remove the last element from list at ReactiveRedisConnection.KeyCommand.getKey(), append it to ReactiveListCommands.BRPopLPushCommand.getDestination() and return its value.
Blocks connection until element available or ReactiveListCommands.BRPopLPushCommand.getTimeout() reached.

Parameters:

commands - must not be null.

Returns:

See Also:

• Redis Documentation: BRPOPLPUSH