Revert

pbernet · May 21, 2024 · e59f281 · e59f281
1 parent daa2f19
commit e59f281
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/test/scala/alpakka/influxdb/InfluxdbIT.java b/src/test/scala/alpakka/influxdb/InfluxdbIT.java
@@ -18,6 +18,7 @@
 import java.util.concurrent.CompletionStage;
 import java.util.concurrent.ExecutionException;
 import java.util.concurrent.TimeUnit;
+import java.util.stream.Collectors;
 import java.util.stream.IntStream;
 
 import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
@@ -70,7 +71,7 @@ void testWriteAndRead() {
 
         List<CompletionStage<Done>> futList = IntStream.rangeClosed(1, maxClients).boxed().parallel()
                 .map(i -> influxDBWriter.writeTestPoints(nPoints, "sensor" + i))
-                .toList();
+                .collect(Collectors.toList());
         assertThat(CompletableFuture.allOf(futList.toArray(new CompletableFuture[futList.size()]))).succeedsWithin(5 * maxClients, TimeUnit.SECONDS);
 
         // TODO Activate, when "com.influxdb" %% "influxdb-client-scala" is available for pekko