Commit cf160e7

committed

Add multiple reactive keys exist checker

1 parent 3ab09fb commit cf160e7Copy full SHA for cf160e7

File tree

2 files changed

+39

-3

lines changed

src
- main/java/org/springframework/data/redis/connection
  - ReactiveKeyCommands.java
- test/java/org/springframework/data/redis/connection/lettuce
  - LettuceReactiveKeyCommandsIntegrationTests.java

2 files changed

+39

-3

lines changed

`‎src/main/java/org/springframework/data/redis/connection/ReactiveKeyCommands.java‎`

Lines changed: 14 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -175,6 +175,20 @@ default Mono<Boolean> exists(ByteBuffer key) {`
`175`	`175`
`176`	`176`	`return exists(Mono.just(new KeyCommand(key))).next().map(BooleanResponse::getOutput);`
`177`	`177`	`}`
	`178`	`+ /**`
	`179`	`+ * Determine if given all {@literal keys} exist.`
	`180`	`+ *`
	`181`	`+ * @param keys must not be {@literal null} or {@literal empty}.`
	`182`	`+ * @return {@link Mono} emitting {@literal true} if all keys exist.`
	`183`	`+ * @see <a href="https://redis.io/commands/exists">Redis Documentation: EXISTS</a>`
	`184`	`+ */`
	`185`	`+ default Mono<Boolean> exists(List<ByteBuffer> keys) {`
	`186`	`+`
	`187`	`+ Assert.notNull(keys, "Keys must not be null");`
	`188`	`+ Assert.notEmpty(keys, "Keys must not be empty");`
	`189`	`+`
	`190`	`+ return exists(Flux.fromIterable(keys).map(KeyCommand::new)).all(BooleanResponse::getOutput);`
	`191`	`+ }`
`178`	`192`
`179`	`193`	`/**`
`180`	`194`	`* Determine if given {@literal key} exists.`

`‎src/test/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveKeyCommandsIntegrationTests.java‎`

Lines changed: 25 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -66,6 +66,28 @@ void existsShouldReturnFalseForNonExistingKeys() {`
`66`	`66`	`connection.keyCommands().exists(KEY_1_BBUFFER).as(StepVerifier::create).expectNext(false).verifyComplete();`
`67`	`67`	`}`
`68`	`68`
	`69`	`+ @ParameterizedRedisTest`
	`70`	`+ void existsShouldReturnTrueWhenKeysExist() {`
	`71`	`+`
	`72`	`+ nativeCommands.set(KEY_1, VALUE_1);`
	`73`	`+ nativeCommands.set(KEY_2, VALUE_2);`
	`74`	`+`
	`75`	`+ connection.keyCommands().exists(Arrays.asList(KEY_1_BBUFFER, KEY_2_BBUFFER)).as(StepVerifier::create)`
	`76`	`+ .expectNext(true)`
	`77`	`+ .verifyComplete();`
	`78`	`+ }`
	`79`	`+`
	`80`	`+ @ParameterizedRedisTest`
	`81`	`+ void existsShouldReturnFalseWhenKeysDoNotExist() {`
	`82`	`+`
	`83`	`+ nativeCommands.set(KEY_1, VALUE_1);`
	`84`	`+`
	`85`	`+ connection.keyCommands().exists(Arrays.asList(KEY_1_BBUFFER, KEY_2_BBUFFER)).as(StepVerifier::create)`
	`86`	`+ .expectNext(false) //`
	`87`	`+ .verifyComplete();`
	`88`	`+ }`
	`89`	`+`
	`90`	`+`
`69`	`91`	`@ParameterizedRedisTest // DATAREDIS-525`
`70`	`92`	`void typeShouldReturnTypeCorrectly() {`
`71`	`93`
`@@ -164,7 +186,7 @@ void renameShouldAlterKeyNameCorrectly() {`
`164`	`186`	`connection.keyCommands().rename(KEY_1_BBUFFER, KEY_2_BBUFFER).as(StepVerifier::create).expectNext(true)`
`165`	`187`	`.verifyComplete();`
`166`	`188`	`assertThat(nativeCommands.exists(KEY_2)).isEqualTo(1L);`
`167`		`- assertThat(nativeCommands.exists(KEY_1)).isEqualTo(0L);`
	`189`	`+ assertThat(nativeCommands.exists(KEY_1)).isZero();`
`168`	`190`	`}`
`169`	`191`
`170`	`192`	`@ParameterizedRedisTest // DATAREDIS-525`
`@@ -183,7 +205,7 @@ void renameNXShouldAlterKeyNameCorrectly() {`
`183`	`205`	`.verifyComplete();`
`184`	`206`
`185`	`207`	`assertThat(nativeCommands.exists(KEY_2)).isEqualTo(1L);`
`186`		`- assertThat(nativeCommands.exists(KEY_1)).isEqualTo(0L);`
	`208`	`+ assertThat(nativeCommands.exists(KEY_1)).isZero();`
`187`	`209`	`}`
`188`	`210`
`189`	`211`	`@ParameterizedRedisTest // DATAREDIS-525`
`@@ -395,7 +417,7 @@ void shouldMoveToDatabase() {`
`395`	`417`	`.expectNext(true) //`
`396`	`418`	`.expectComplete() //`
`397`	`419`	`.verify();`
`398`		`- assertThat(nativeCommands.exists(KEY_1)).isEqualTo(0L);`
	`420`	`+ assertThat(nativeCommands.exists(KEY_1)).isZero();`
`399`	`421`	`}`
`400`	`422`
`401`	`423`	`@ParameterizedRedisTest // DATAREDIS-694`

0 commit comments

Comments

(0)

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit cf160e7

File tree

2 files changed

2 files changed

`‎src/main/java/org/springframework/data/redis/connection/ReactiveKeyCommands.java‎`

`‎src/test/java/org/springframework/data/redis/connection/lettuce/LettuceReactiveKeyCommandsIntegrationTests.java‎`

0 commit comments