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 reactor.core.publisher.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.
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BLMoveCommand>>	bLMove(org.reactivestreams.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 reactor.core.publisher.Mono<ReactiveListCommands.PopResult>	blPop(List<ByteBuffer> keys, Duration timeout)	Removes and returns first element from lists stored at keys.
reactor.core.publisher.Flux<ReactiveListCommands.PopResponse>	bPop(org.reactivestreams.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 reactor.core.publisher.Mono<ReactiveListCommands.PopResult>	brPop(List<ByteBuffer> keys, Duration timeout)	Removes and returns last element from lists stored at keys.
default reactor.core.publisher.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.
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BRPopLPushCommand>>	bRPopLPush(org.reactivestreams.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 reactor.core.publisher.Mono<ByteBuffer>	lIndex(ByteBuffer key, long index)	Get element at index form list at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LIndexCommand>>	lIndex(org.reactivestreams.Publisher<ReactiveListCommands.LIndexCommand> commands)	Get element at ReactiveListCommands.LIndexCommand.getIndex() form list at ReactiveRedisConnection.KeyCommand.getKey().
default reactor.core.publisher.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.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LInsertCommand,Long>>	lInsert(org.reactivestreams.Publisher<ReactiveListCommands.LInsertCommand> commands)	Insert ReactiveListCommands.LInsertCommand.getValue() RedisListCommands.Position.BEFORE or RedisListCommands.Position.AFTER existing ReactiveListCommands.LInsertCommand.getPivot() for ReactiveRedisConnection.KeyCommand.getKey()
default reactor.core.publisher.Mono<Long>	lLen(ByteBuffer key)	Get the size of list stored at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	lLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get the size of list stored at ReactiveRedisConnection.KeyCommand.getKey()
default reactor.core.publisher.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.
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LMoveCommand>>	lMove(org.reactivestreams.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 reactor.core.publisher.Mono<ByteBuffer>	lPop(ByteBuffer key)	Removes and returns first element in list stored at key.
default reactor.core.publisher.Flux<ByteBuffer>	lPop(ByteBuffer key, long count)	Removes and returns first count elements in list stored at key.
default reactor.core.publisher.Mono<Long>	lPos(ByteBuffer key, ByteBuffer element)	Get first index of the element from list at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LPosCommand,Long>>	lPos(org.reactivestreams.Publisher<ReactiveListCommands.LPosCommand> commands)	Get indices of the element from list at ReactiveRedisConnection.KeyCommand.getKey().
default reactor.core.publisher.Flux<Long>	lPos(ReactiveListCommands.LPosCommand command)	Get indices of the element from list at ReactiveRedisConnection.KeyCommand.getKey().
default reactor.core.publisher.Mono<Long>	lPush(ByteBuffer key, List<ByteBuffer> values)	Prepend values to key.
default reactor.core.publisher.Mono<Long>	lPushX(ByteBuffer key, ByteBuffer value)	Prepend value to key if key already exists.
default reactor.core.publisher.Flux<ByteBuffer>	lRange(ByteBuffer key, long start, long end)	Get elements between start and end from list at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.RangeCommand,reactor.core.publisher.Flux<ByteBuffer>>>	lRange(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands)	Get elements in ReactiveRedisConnection.RangeCommand.getRange() from list at ReactiveRedisConnection.KeyCommand.getKey()
default reactor.core.publisher.Mono<Long>	lRem(ByteBuffer key, Long count, ByteBuffer value)	Removes the first count occurrences of value from the list stored at key.
default reactor.core.publisher.Mono<Long>	lRem(ByteBuffer key, ByteBuffer value)	Removes all occurrences of value from the list stored at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,Long>>	lRem(org.reactivestreams.Publisher<ReactiveListCommands.LRemCommand> commands)	Removes the ReactiveListCommands.LRemCommand.getCount() occurrences of ReactiveListCommands.LRemCommand.getValue() from the list stored at ReactiveRedisConnection.KeyCommand.getKey().
default reactor.core.publisher.Mono<Boolean>	lSet(ByteBuffer key, long index, ByteBuffer value)	Set the value list element at index.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveListCommands.LSetCommand>>	lSet(org.reactivestreams.Publisher<ReactiveListCommands.LSetCommand> commands)	Set the ReactiveListCommands.LSetCommand.getValue() list element at ReactiveRedisConnection.KeyCommand.getKey().
default reactor.core.publisher.Mono<Boolean>	lTrim(ByteBuffer key, long start, long end)	Trim list at key to elements between start and end.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.RangeCommand>>	lTrim(org.reactivestreams.Publisher<ReactiveRedisConnection.RangeCommand> commands)	Trim list at ReactiveRedisConnection.KeyCommand.getKey() to elements within ReactiveRedisConnection.RangeCommand.getRange().
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.PopCommand>>	pop(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands)	Removes and returns last element in list stored at ReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveListCommands.PopCommand,reactor.core.publisher.Flux<ByteBuffer>>>	popList(org.reactivestreams.Publisher<ReactiveListCommands.PopCommand> commands)	Removes and returns last element in list stored at ReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.PushCommand,Long>>	push(org.reactivestreams.Publisher<ReactiveListCommands.PushCommand> commands)	Prepend ReactiveListCommands.PushCommand.getValues() to ReactiveRedisConnection.KeyCommand.getKey().
default reactor.core.publisher.Mono<ByteBuffer>	rPop(ByteBuffer key)	Removes and returns last element in list stored at key.
default reactor.core.publisher.Flux<ByteBuffer>	rPop(ByteBuffer key, long count)	Removes and returns last count elements in list stored at key.
default reactor.core.publisher.Mono<ByteBuffer>	rPopLPush(ByteBuffer source, ByteBuffer destination)	Remove the last element from list at source, append it to destination and return its value.
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.RPopLPushCommand>>	rPopLPush(org.reactivestreams.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 reactor.core.publisher.Mono<Long>	rPush(ByteBuffer key, List<ByteBuffer> values)	Append values to key.
default reactor.core.publisher.Mono<Long>	rPushX(ByteBuffer key, ByteBuffer value)	Append values to key only if key already exists.

Method Details

rPush

default reactor.core.publisher.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 reactor.core.publisher.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 reactor.core.publisher.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.PushCommand,Long>> push(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> lLen(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveRedisConnection.RangeCommand,reactor.core.publisher.Flux<ByteBuffer>>> lRange(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveRedisConnection.RangeCommand>> lTrim(org.reactivestreams.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 reactor.core.publisher.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LPosCommand,Long>> lPos(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LIndexCommand>> lIndex(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LInsertCommand,Long>> lInsert(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.LMoveCommand>> lMove(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BLMoveCommand>> bLMove(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveListCommands.LSetCommand>> lSet(org.reactivestreams.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 reactor.core.publisher.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveListCommands.LRemCommand,Long>> lRem(org.reactivestreams.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 reactor.core.publisher.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 reactor.core.publisher.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 reactor.core.publisher.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.PopCommand>> pop(org.reactivestreams.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

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveListCommands.PopCommand,reactor.core.publisher.Flux<ByteBuffer>>> popList(org.reactivestreams.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 reactor.core.publisher.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveListCommands.PopResponse> bPop(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.RPopLPushCommand>> rPopLPush(org.reactivestreams.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 reactor.core.publisher.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

reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveListCommands.BRPopLPushCommand>> bRPopLPush(org.reactivestreams.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