Change scheduler

EAddario · Apr 3, 2024 · 0259297 · 0259297
1 parent 37cf232
commit 0259297
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/backend-service/src/main/java/org/addario/backendservice/ReactiveNames.java b/backend-service/src/main/java/org/addario/backendservice/ReactiveNames.java
@@ -26,7 +26,7 @@ public static Mono<String> getName(int count) {
         var finalCounts = Flux.fromIterable(names)
                 .buffer(Runtime.getRuntime().availableProcessors())
                 .parallel()
-                .runOn(Schedulers.newParallel("Aggregator"))
+                .runOn(Schedulers.boundedElastic())
                 .flatMap(ReactiveNames::processBatch)
                 .sequential()
                 .reduce(new HashMap<>(), ReactiveNames::mergeIntermediateCount)