org.springframework.data.redis.connection.lettuce

Class LettuceReactiveSetCommands

java.lang.Object

org.springframework.data.redis.connection.lettuce.LettuceReactiveSetCommands

All Implemented Interfaces:

ReactiveSetCommands

Direct Known Subclasses:

LettuceReactiveClusterSetCommands

public class LettuceReactiveSetCommands
extends Object
implements ReactiveSetCommands

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

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

ReactiveSetCommands.SAddCommand, ReactiveSetCommands.SDiffCommand, ReactiveSetCommands.SDiffStoreCommand, ReactiveSetCommands.SInterCommand, ReactiveSetCommands.SInterStoreCommand, ReactiveSetCommands.SIsMemberCommand, ReactiveSetCommands.SMoveCommand, ReactiveSetCommands.SRandMembersCommand, ReactiveSetCommands.SRemCommand, ReactiveSetCommands.SUnionCommand, ReactiveSetCommands.SUnionStoreCommand

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected LettuceReactiveRedisConnection	getConnection()
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,Long>>	sAdd(org.reactivestreams.Publisher<ReactiveSetCommands.SAddCommand> commands) Add given ReactiveSetCommands.SAddCommand.getValues() to set at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	sCard(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get size of set at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SDiffCommand,ByteBuffer>>	sDiff(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffCommand> commands) Returns the diff of the members of all given sets at ReactiveSetCommands.SInterCommand.getKeys().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,Long>>	sDiffStore(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffStoreCommand> commands) Diff all given sets at keys and store result in destinationKey.
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SInterCommand,ByteBuffer>>	sInter(org.reactivestreams.Publisher<ReactiveSetCommands.SInterCommand> commands) Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,Long>>	sInterStore(org.reactivestreams.Publisher<ReactiveSetCommands.SInterStoreCommand> commands) Intersect all given sets at keys and store result in destinationKey.
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SIsMemberCommand>>	sIsMember(org.reactivestreams.Publisher<ReactiveSetCommands.SIsMemberCommand> commands) Check if set at ReactiveRedisConnection.KeyCommand.getKey() contains ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveRedisConnection.KeyCommand,ByteBuffer>>	sMembers(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Get all elements of set at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SMoveCommand>>	sMove(org.reactivestreams.Publisher<ReactiveSetCommands.SMoveCommand> commands) Move ReactiveSetCommands.SMoveCommand.getValue() from ReactiveRedisConnection.KeyCommand.getKey() to ReactiveSetCommands.SMoveCommand.getDestination().
reactor.core.publisher.Flux<ReactiveRedisConnection.ByteBufferResponse<ReactiveRedisConnection.KeyCommand>>	sPop(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Remove and return a random member from set at ReactiveRedisConnection.KeyCommand.getKey()
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SRandMembersCommand,ByteBuffer>>	sRandMember(org.reactivestreams.Publisher<ReactiveSetCommands.SRandMembersCommand> commands) Get ReactiveSetCommands.SRandMembersCommand.getCount() random elements from set at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,Long>>	sRem(org.reactivestreams.Publisher<ReactiveSetCommands.SRemCommand> commands) Remove given ReactiveSetCommands.SRemCommand.getValues() from set at ReactiveRedisConnection.KeyCommand.getKey().
reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SUnionCommand,ByteBuffer>>	sUnion(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionCommand> commands) Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,Long>>	sUnionStore(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionStoreCommand> commands) Union all given sets at keys and store result in destinationKey.

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.ReactiveSetCommands

sAdd, sAdd, sCard, sDiff, sDiffStore, sInter, sInterStore, sIsMember, sMembers, sMove, sPop, sRandMember, sRandMember, sRem, sRem, sUnion, sUnionStore

Constructor Detail

LettuceReactiveSetCommands

public LettuceReactiveSetCommands(LettuceReactiveRedisConnection connection)

Create new LettuceReactiveSetCommands.

Parameters:

connection - must not be null.

Method Detail

sAdd

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SAddCommand,Long>> sAdd(org.reactivestreams.Publisher<ReactiveSetCommands.SAddCommand> commands)

Description copied from interface: ReactiveSetCommands

Add given ReactiveSetCommands.SAddCommand.getValues() to set at ReactiveRedisConnection.KeyCommand.getKey().

Specified by:

sAdd in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sRem

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SRemCommand,Long>> sRem(org.reactivestreams.Publisher<ReactiveSetCommands.SRemCommand> commands)

Description copied from interface: ReactiveSetCommands

Remove given ReactiveSetCommands.SRemCommand.getValues() from set at ReactiveRedisConnection.KeyCommand.getKey().

Specified by:

sRem in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sPop

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

Description copied from interface: ReactiveSetCommands

Remove and return a random member from set at ReactiveRedisConnection.KeyCommand.getKey()

Specified by:

sPop in interface ReactiveSetCommands

Returns:

sMove

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SMoveCommand>> sMove(org.reactivestreams.Publisher<ReactiveSetCommands.SMoveCommand> commands)

Description copied from interface: ReactiveSetCommands

Move ReactiveSetCommands.SMoveCommand.getValue() from ReactiveRedisConnection.KeyCommand.getKey() to ReactiveSetCommands.SMoveCommand.getDestination().

Specified by:

sMove in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sCard

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

Description copied from interface: ReactiveSetCommands

Get size of set at ReactiveRedisConnection.KeyCommand.getKey().

Specified by:

sCard in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sIsMember

public reactor.core.publisher.Flux<ReactiveRedisConnection.BooleanResponse<ReactiveSetCommands.SIsMemberCommand>> sIsMember(org.reactivestreams.Publisher<ReactiveSetCommands.SIsMemberCommand> commands)

Description copied from interface: ReactiveSetCommands

Check if set at ReactiveRedisConnection.KeyCommand.getKey() contains ReactiveRedisConnection.KeyCommand.getKey().

Specified by:

sIsMember in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sInter

public reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SInterCommand,ByteBuffer>> sInter(org.reactivestreams.Publisher<ReactiveSetCommands.SInterCommand> commands)

Description copied from interface: ReactiveSetCommands

Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().

Specified by:

sInter in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sInterStore

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SInterStoreCommand,Long>> sInterStore(org.reactivestreams.Publisher<ReactiveSetCommands.SInterStoreCommand> commands)

Description copied from interface: ReactiveSetCommands

Intersect all given sets at keys and store result in destinationKey.

Specified by:

sInterStore in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sUnion

public reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SUnionCommand,ByteBuffer>> sUnion(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionCommand> commands)

Description copied from interface: ReactiveSetCommands

Returns the members intersecting all given sets at ReactiveSetCommands.SInterCommand.getKeys().

Specified by:

sUnion in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sUnionStore

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SUnionStoreCommand,Long>> sUnionStore(org.reactivestreams.Publisher<ReactiveSetCommands.SUnionStoreCommand> commands)

Description copied from interface: ReactiveSetCommands

Union all given sets at keys and store result in destinationKey.

Specified by:

sUnionStore in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sDiff

public reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SDiffCommand,ByteBuffer>> sDiff(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffCommand> commands)

Description copied from interface: ReactiveSetCommands

Returns the diff of the members of all given sets at ReactiveSetCommands.SInterCommand.getKeys().

Specified by:

sDiff in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sDiffStore

public reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveSetCommands.SDiffStoreCommand,Long>> sDiffStore(org.reactivestreams.Publisher<ReactiveSetCommands.SDiffStoreCommand> commands)

Description copied from interface: ReactiveSetCommands

Diff all given sets at keys and store result in destinationKey.

Specified by:

sDiffStore in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sMembers

public reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveRedisConnection.KeyCommand,ByteBuffer>> sMembers(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Description copied from interface: ReactiveSetCommands

Get all elements of set at ReactiveRedisConnection.KeyCommand.getKey().

Specified by:

sMembers in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

sRandMember

public reactor.core.publisher.Flux<ReactiveRedisConnection.MultiValueResponse<ReactiveSetCommands.SRandMembersCommand,ByteBuffer>> sRandMember(org.reactivestreams.Publisher<ReactiveSetCommands.SRandMembersCommand> commands)

Description copied from interface: ReactiveSetCommands

Get ReactiveSetCommands.SRandMembersCommand.getCount() random elements from set at ReactiveRedisConnection.KeyCommand.getKey().

Specified by:

sRandMember in interface ReactiveSetCommands

Parameters:

commands - must not be null.

Returns:

getConnection

protected LettuceReactiveRedisConnection getConnection()