org.springframework.data.redis.connection.lettuce

Class LettuceReactiveNumberCommands

java.lang.Object

org.springframework.data.redis.connection.lettuce.LettuceReactiveNumberCommands

All Implemented Interfaces:

ReactiveNumberCommands

Direct Known Subclasses:

LettuceReactiveClusterNumberCommands

public class LettuceReactiveNumberCommands
extends Object
implements ReactiveNumberCommands

Since:

2.0

Author:

Christoph Strobl, Mark Paluch

Nested Class Summary

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

ReactiveNumberCommands.DecrByCommand<T extends Number>, ReactiveNumberCommands.HIncrByCommand<T extends Number>, ReactiveNumberCommands.IncrByCommand<T extends Number>

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	decr(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Decrement value of key by 1.
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.DecrByCommand<T>,T>>	decrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.DecrByCommand<T>> commands) Decrement value of key by value.
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.HIncrByCommand<T>,T>>	hIncrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.HIncrByCommand<T>> commands) Increment value of a hash field by the given value.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	incr(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands) Increment value of key by 1.
<T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.IncrByCommand<T>,T>>	incrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.IncrByCommand<T>> commands) Increment value of key by value.

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

decr, decrBy, hIncrBy, incr, incrBy

Constructor Detail

LettuceReactiveNumberCommands

public LettuceReactiveNumberCommands(LettuceReactiveRedisConnection connection)

Create new LettuceReactiveStringCommands.

Parameters:

connection - must not be null.

Method Detail

incr

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

Description copied from interface: ReactiveNumberCommands

Increment value of key by 1.

Specified by:

incr in interface ReactiveNumberCommands

Parameters:

commands - must not be null.

Returns:

incrBy

public <T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.IncrByCommand<T>,T>> incrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.IncrByCommand<T>> commands)

Description copied from interface: ReactiveNumberCommands

Increment value of key by value.

Specified by:

incrBy in interface ReactiveNumberCommands

Parameters:

commands - must not be null.

Returns:

decr

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

Description copied from interface: ReactiveNumberCommands

Decrement value of key by 1.

Specified by:

decr in interface ReactiveNumberCommands

Parameters:

commands - must not be null.

Returns:

decrBy

public <T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.DecrByCommand<T>,T>> decrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.DecrByCommand<T>> commands)

Description copied from interface: ReactiveNumberCommands

Decrement value of key by value.

Specified by:

decrBy in interface ReactiveNumberCommands

Parameters:

commands - must not be null.

Returns:

hIncrBy

public <T extends Number> reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveNumberCommands.HIncrByCommand<T>,T>> hIncrBy(org.reactivestreams.Publisher<ReactiveNumberCommands.HIncrByCommand<T>> commands)

Description copied from interface: ReactiveNumberCommands

Increment value of a hash field by the given value.

Specified by:

hIncrBy in interface ReactiveNumberCommands

Returns: