Retain order doing reactive save operations with multiple elements.

christophstrobl · christophstrobl · commit 98b07a4307c5 · 2024-10-31T07:56:00.000+01:00
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/SimpleReactiveMongoRepository.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/SimpleReactiveMongoRepository.java
@@ -114,7 +114,7 @@ public <S extends T> Flux<S> saveAll(Iterable<S> entities) {
 
 		return source.stream().allMatch(entityInformation::isNew) ? //
 				mongoOperations.insert(source.stream().collect(Collectors.toList()), entityInformation.getCollectionName()) : //
-				Flux.fromIterable(entities).flatMap(this::save);
+				Flux.fromIterable(entities).flatMapSequential(this::save);
 	}
 
 	@Override

Original file line number	Diff line number	Diff line change
`@@ -114,7 +114,7 @@ public <S extends T> Flux<S> saveAll(Iterable<S> entities) {`
`114`	`114`
`115`	`115`	`return source.stream().allMatch(entityInformation::isNew) ? //`
`116`	`116`	`mongoOperations.insert(source.stream().collect(Collectors.toList()), entityInformation.getCollectionName()) : //`
`117`		`- Flux.fromIterable(entities).flatMap(this::save);`
	`117`	`+ Flux.fromIterable(entities).flatMapSequential(this::save);`
`118`	`118`	`}`
`119`	`119`
`120`	`120`	`@Override`