diff --git a/src/test/groovy/graphql/execution/reactive/tck/CompletionStageMappingPublisherTckVerificationTest.java b/src/test/groovy/graphql/execution/reactive/tck/CompletionStageMappingPublisherTckVerificationTest.java index 9c58e3fd6e..f68c7d3fab 100644 --- a/src/test/groovy/graphql/execution/reactive/tck/CompletionStageMappingPublisherTckVerificationTest.java +++ b/src/test/groovy/graphql/execution/reactive/tck/CompletionStageMappingPublisherTckVerificationTest.java @@ -10,6 +10,7 @@ import java.time.Duration; import java.util.concurrent.CompletableFuture; import java.util.concurrent.CompletionStage; +import java.util.concurrent.Executors; import java.util.function.Function; /** @@ -31,7 +32,7 @@ public long maxElementsFromPublisher() { @Override public Publisher createPublisher(long elements) { Publisher publisher = Flowable.range(0, (int) elements); - Function> mapper = i -> CompletableFuture.supplyAsync(() -> i + "!"); + Function> mapper = i -> CompletableFuture.supplyAsync(() -> i + "!", Executors.newSingleThreadExecutor()); return new CompletionStageMappingPublisher<>(publisher, mapper); }