diff --git a/akka-stream-tests/src/test/java/akka/stream/javadsl/SourceRunWithTest.java b/akka-stream-tests/src/test/java/akka/stream/javadsl/SourceRunWithTest.java new file mode 100644 index 0000000000..235298ab2e --- /dev/null +++ b/akka-stream-tests/src/test/java/akka/stream/javadsl/SourceRunWithTest.java @@ -0,0 +1,36 @@ +/* + * Copyright (C) 2009-2019 Lightbend Inc. + */ + +package akka.stream.javadsl; + +import akka.actor.ActorSystem; +import akka.stream.Materializer; + +import java.util.concurrent.CompletableFuture; + +public class SourceRunWithTest { + + public void sourceRunWithCompileOnlyTest() { + Materializer mat = null; + ActorSystem system = null; + + // Coverage for #27944 + Source.empty().runWith(Sink.seq(), mat); + Source.empty().runWith(Sink.seq(), system); + + Source.empty().runFold(0L, (n, acc) -> n + acc, mat); + Source.empty().runFold(0L, (n, acc) -> n + acc, system); + + Source.empty() + .runFoldAsync(0L, (n, acc) -> CompletableFuture.completedFuture(n + acc), mat); + Source.empty() + .runFoldAsync(0L, (n, acc) -> CompletableFuture.completedFuture(n + acc), system); + + Source.empty().runReduce((a, b) -> a + b, mat); + Source.empty().runReduce((a, b) -> a + b, system); + + Source.empty().runForeach(str -> System.out.println(str), mat); + Source.empty().runForeach(str -> System.out.println(str), system); + } +}