DATACOUCH-146 - Use only last emission to create a Mono for delete collection

Original pull request: #130.
This commit is contained in:
Subhashni Balakrishnan
2017-01-30 15:53:52 -08:00
parent d62f4bbe8c
commit d9510dc158

View File

@@ -200,7 +200,10 @@ public class SimpleReactiveCouchbaseRepository<T, ID extends Serializable> imple
@Override
public Mono<Void> delete(Iterable<? extends T> entities) {
Assert.notNull(entities, "The given Iterable of entities must not be null!");
return mapMono(operations.remove(entities).map(res -> Observable.<Void>empty()).toSingle());
return mapMono(operations
.remove(entities)
.last()
.map(res -> Observable.<Void>empty()).toSingle());
}