From bd79fdd68b98a99fe7bdc53188b336a207a9c88d Mon Sep 17 00:00:00 2001 From: "Greg L. Turnquist" Date: Thu, 12 May 2022 13:42:54 -0500 Subject: [PATCH] Migrate to Reactor Schedulers.boundedElastic() API. Closes #1264. --- .../core/ReactiveCassandraBatchTemplateIntegrationTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 index 27d3dd624..cf3c57a6b 100644 --- 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 @@ class ReactiveCassandraBatchTemplateIntegrationTests extends AbstractKeyspaceCre 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()