diff --git a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java index 21188e19be..bd2a77ea7d 100644 --- a/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java +++ b/akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java @@ -60,8 +60,8 @@ public class Monitor { // Periodically check the monitor Source.tick(Duration.ofMillis(200), Duration.ofMillis(400), "") - .runForeach(__ -> printMonitorState(monitor.state()), actorSystem); - // #monitor + .runForeach(__ -> printMonitorState(monitor.state()), actorSystem); + // #monitor run.second().toCompletableFuture().whenComplete((x, t) -> actorSystem.terminate()); }