diff --git a/spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/core/R2dbcEntityTemplate.java b/spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/core/R2dbcEntityTemplate.java
index 788aa118..d327042c 100644
--- a/spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/core/R2dbcEntityTemplate.java
+++ b/spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/core/R2dbcEntityTemplate.java
@@ -380,7 +380,7 @@ public class R2dbcEntityTemplate implements R2dbcEntityOperations, BeanFactoryAw
 			return (P) ((Mono<?>) result).flatMap(it -> maybeCallAfterConvert(it, tableName));
 		}
 
-		return (P) ((Flux<?>) result).flatMap(it -> maybeCallAfterConvert(it, tableName));
+		return (P) ((Flux<?>) result).concatMap(it -> maybeCallAfterConvert(it, tableName));
 	}
 
 	private <T> RowsFetchSpec<T> doSelect(Query query, Class<?> entityClass, SqlIdentifier tableName,
@@ -942,7 +942,7 @@ public class R2dbcEntityTemplate implements R2dbcEntityOperations, BeanFactoryAw
 
 		@Override
 		public Flux<T> all() {
-			return delegate.all().flatMap(it -> maybeCallAfterConvert(it, tableName));
+			return delegate.all().concatMap(it -> maybeCallAfterConvert(it, tableName));
 		}
 	}