org.springframework.data.redis.connection.lettuce

Class LettuceReactiveClusterSetCommands

java.lang.Object

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

org.springframework.data.redis.connection.lettuce.LettuceReactiveClusterSetCommands

All Implemented Interfaces:

ReactiveClusterSetCommands, ReactiveSetCommands

public class LettuceReactiveClusterSetCommands
extends LettuceReactiveSetCommands
implements ReactiveClusterSetCommands

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
LettuceReactiveClusterSetCommands(LettuceReactiveRedisConnection connection) Create new LettuceReactiveSetCommands.

Method Summary

Modifier and Type	Method and Description
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.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.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 org.springframework.data.redis.connection.lettuce.LettuceReactiveSetCommands

getConnection, sAdd, sCard, sIsMember, sMembers, sPop, sRandMember, sRem

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, sAdd, sCard, sCard, sDiff, sDiffStore, sInter, sInterStore, sIsMember, sIsMember, sMembers, sMembers, sMove, sPop, sPop, sRandMember, sRandMember, sRandMember, sRem, sRem, sRem, sUnion, sUnionStore

Constructor Detail

LettuceReactiveClusterSetCommands

public LettuceReactiveClusterSetCommands(LettuceReactiveRedisConnection connection)

Create new LettuceReactiveSetCommands.

Parameters:

connection - must not be null.

Method Detail

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

Overrides:

sUnion in class LettuceReactiveSetCommands

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

Overrides:

sUnionStore in class LettuceReactiveSetCommands

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

Overrides:

sInter in class LettuceReactiveSetCommands

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

Overrides:

sInterStore in class LettuceReactiveSetCommands

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

Overrides:

sDiff in class LettuceReactiveSetCommands

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

Overrides:

sDiffStore in class LettuceReactiveSetCommands

Parameters:

commands - must not be null.

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

Overrides:

sMove in class LettuceReactiveSetCommands

Parameters:

commands - must not be null.

Returns: