Spring/spring-data-redis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATAREDIS-784 - Add support for reactive increment and decrement commands to ReactiveValueOperations.

Browse Source 
We now support reactive execution of the following increment and decrement commands through ReactiveValueOperations:

- INCR
- INCRBY
- INCRBYFLOAT
- DECR
- DECRBY

Original pull request: #322.
This commit is contained in:
Jiahe Cai (佳何 蔡)
2018-03-11 20:07:40 +08:00
committed by Mark Paluch
parent 452feb9420
commit 8857f96b9f
3 changed files with 151 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

56
src/test/java/org/springframework/data/redis/core/DefaultReactiveValueOperationsIntegrationTests.java
View File

@@ -384,4 +384,60 @@ public class DefaultReactiveValueOperationsIntegrationTests<K, V> {
StepVerifier.create(valueOperations.size(key)).expectNext(0L).verifyComplete();
}
@Test // DATAREDIS-784
public void increment() {
K key = keyFactory.instance();
StepVerifier.create(valueOperations.increment(key)).expectNext(1L).verifyComplete();
StepVerifier.create(valueOperations.increment(key)).expectNext(2L).verifyComplete();
}
@Test // DATAREDIS-784
public void incrementByLongDelta() {
K key = keyFactory.instance();
StepVerifier.create(valueOperations.incrementBy(key, 2L)).expectNext(2L).verifyComplete();
StepVerifier.create(valueOperations.incrementBy(key, -3L)).expectNext(-1L).verifyComplete();
StepVerifier.create(valueOperations.incrementBy(key, 1L)).expectNext(0L).verifyComplete();
}
@Test // DATAREDIS-784
public void incrementByFloatDelta() {
K key = keyFactory.instance();
StepVerifier.create(valueOperations.incrementBy(key, 0.1)).expectNext(0.1).verifyComplete();
StepVerifier.create(valueOperations.incrementBy(key, -0.3)).expectNext(-0.2).verifyComplete();
StepVerifier.create(valueOperations.incrementBy(key, 0.2)).expectNext(0.0).verifyComplete();
}
@Test // DATAREDIS-784
public void decrement() {
K key = keyFactory.instance();
StepVerifier.create(valueOperations.decrement(key)).expectNext(-1L).verifyComplete();
StepVerifier.create(valueOperations.decrement(key)).expectNext(-2L).verifyComplete();
}
@Test // DATAREDIS-784
public void decrementByLongDelta() {
K key = keyFactory.instance();
StepVerifier.create(valueOperations.decrementBy(key, 2L)).expectNext(-2L).verifyComplete();
StepVerifier.create(valueOperations.decrementBy(key, -3L)).expectNext(1L).verifyComplete();
StepVerifier.create(valueOperations.decrementBy(key, 1L)).expectNext(0L).verifyComplete();
}
}