Fix SingleEntityExecution when a single element is emitted.

mp911de · mp911de · commit 8eac3fed03c2 · 2021-03-22T11:38:41.000+01:00
We now correctly exit the handler to avoid element emission followed by an error signal. Closes #1107
diff --git a/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/repository/query/ReactiveCassandraQueryExecution.java b/spring-data-cassandra/src/main/java/org/springframework/data/cassandra/repository/query/ReactiveCassandraQueryExecution.java
@@ -150,6 +150,7 @@ public Publisher<? extends Object> execute(Statement<?> statement, Class<?> type
 
 				if (objects.size() == 1 || limiting) {
 					sink.next(objects.get(0));
+					return;
 				}
 
 				sink.error(new IncorrectResultSizeDataAccessException(1, objects.size()));

Original file line number	Diff line number	Diff line change
`@@ -150,6 +150,7 @@ public Publisher<? extends Object> execute(Statement<?> statement, Class<?> type`
`150`	`150`
`151`	`151`	`if (objects.size() == 1 \|\| limiting) {`
`152`	`152`	`sink.next(objects.get(0));`
	`153`	`+ return;`
`153`	`154`	`}`
`154`	`155`
`155`	`156`	`sink.error(new IncorrectResultSizeDataAccessException(1, objects.size()));`