Migrate to Reactor Schedulers.boundedElastic() API.

gregturn · gregturn · commit bd79fdd68b98 · 2022-05-12T13:43:30.000-05:00
Closes #1264.
diff --git a/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/ReactiveCassandraBatchTemplateIntegrationTests.java b/spring-data-cassandra/src/test/java/org/springframework/data/cassandra/core/ReactiveCassandraBatchTemplateIntegrationTests.java
@@ -401,7 +401,7 @@ void shouldSupportMultithreadedMerge() {
 			batchOperations.insert(Mono.just(Arrays.asList(new Group(new GroupKey("users", "0x1", "walter" + random.longs())),
 					new Group(new GroupKey("users", "0x1", "walter" + random.longs())),
 					new Group(new GroupKey("users", "0x1", "walter" + random.longs())),
-					new Group(new GroupKey("users", "0x1", "walter" + random.longs())))).publishOn(Schedulers.elastic()));
+					new Group(new GroupKey("users", "0x1", "walter" + random.longs())))).publishOn(Schedulers.boundedElastic()));
 		}
 
 		batchOperations.execute()

Original file line number	Diff line number	Diff line change
`@@ -401,7 +401,7 @@ void shouldSupportMultithreadedMerge() {`
`401`	`401`	`batchOperations.insert(Mono.just(Arrays.asList(new Group(new GroupKey("users", "0x1", "walter" + random.longs())),`
`402`	`402`	`new Group(new GroupKey("users", "0x1", "walter" + random.longs())),`
`403`	`403`	`new Group(new GroupKey("users", "0x1", "walter" + random.longs())),`
`404`		`- new Group(new GroupKey("users", "0x1", "walter" + random.longs())))).publishOn(Schedulers.elastic()));`
	`404`	`+ new Group(new GroupKey("users", "0x1", "walter" + random.longs())))).publishOn(Schedulers.boundedElastic()));`
`405`	`405`	`}`
`406`	`406`
`407`	`407`	`batchOperations.execute()`