diff --git a/src/main/java/org/springframework/data/couchbase/repository/support/SimpleReactiveCouchbaseRepository.java b/src/main/java/org/springframework/data/couchbase/repository/support/SimpleReactiveCouchbaseRepository.java index c78e9a7c..e6a8af30 100644 --- a/src/main/java/org/springframework/data/couchbase/repository/support/SimpleReactiveCouchbaseRepository.java +++ b/src/main/java/org/springframework/data/couchbase/repository/support/SimpleReactiveCouchbaseRepository.java @@ -200,7 +200,10 @@ public class SimpleReactiveCouchbaseRepository imple @Override public Mono delete(Iterable entities) { Assert.notNull(entities, "The given Iterable of entities must not be null!"); - return mapMono(operations.remove(entities).map(res -> Observable.empty()).toSingle()); + return mapMono(operations + .remove(entities) + .last() + .map(res -> Observable.empty()).toSingle()); }