Pass cas from oneEntity call to one by id.

mikereiche · mikereiche · commit d4bb217fd272 · 2023-03-08T18:31:34.000-08:00
Closes #1388.
diff --git a/src/main/java/org/springframework/data/couchbase/core/ReactiveRemoveByIdOperationSupport.java b/src/main/java/org/springframework/data/couchbase/core/ReactiveRemoveByIdOperationSupport.java
@@ -157,7 +157,7 @@ private void rejectInvalidTransactionalOptions() {
 		public Mono<RemoveResult> oneEntity(Object entity) {
 			ReactiveRemoveByIdSupport op = new ReactiveRemoveByIdSupport(template, domainType, scope, collection, options,
 					persistTo, replicateTo, durabilityLevel, template.support().getCas(entity));
-			return op.one(template.support().getId(entity).toString());
+			return op.withCas(template.support().getCas(entity)).one(template.support().getId(entity).toString());
 		}
 
 		@Override

Original file line number	Diff line number	Diff line change
`@@ -157,7 +157,7 @@ private void rejectInvalidTransactionalOptions() {`
`157`	`157`	`public Mono<RemoveResult> oneEntity(Object entity) {`
`158`	`158`	`ReactiveRemoveByIdSupport op = new ReactiveRemoveByIdSupport(template, domainType, scope, collection, options,`
`159`	`159`	`persistTo, replicateTo, durabilityLevel, template.support().getCas(entity));`
`160`		`- return op.one(template.support().getId(entity).toString());`
	`160`	`+ return op.withCas(template.support().getCas(entity)).one(template.support().getId(entity).toString());`
`161`	`161`	`}`
`162`	`162`
`163`	`163`	`@Override`