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

DATACOUCH-293 - Adapt to API changes in Reactor 3.1.

Browse Source 
Related ticket: spring-projects/spring-data-build#333
This commit is contained in:
Mark Paluch
2017-04-12 15:02:54 +02:00
parent 03bb6372c7
commit 3ecc2cf6cb
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/org/springframework/data/couchbase/repository/support/SimpleReactiveCouchbaseRepository.java
View File

@@ -41,6 +41,7 @@ import reactor.core.publisher.Mono;
* Reactive repository base implementation for Couchbase.
*
* @author Subhashni Balakrishnan
* @author Mark Paluch
* @since 3.0
*/
public class SimpleReactiveCouchbaseRepository<T, ID extends Serializable> implements ReactiveCouchbaseRepository<T, ID> {
@@ -131,8 +132,8 @@ public class SimpleReactiveCouchbaseRepository<T, ID extends Serializable> imple
@Override
public Mono<T> findOne(Mono<ID> mono) {
Assert.notNull(mono, "The given mono must not be null!");
return mono.then(
id -> findOne(id));
return mono.flatMap(
this::findOne);
}
@SuppressWarnings("unchecked")
@@ -145,8 +146,8 @@ public class SimpleReactiveCouchbaseRepository<T, ID extends Serializable> imple
@SuppressWarnings("unchecked")
@Override
public Mono<Boolean> exists(Mono<ID> mono) {
return mono.then(
id -> exists(id));
return mono.flatMap(
this::exists);
}
@SuppressWarnings("unchecked")