raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

javafmt

Browse source
This commit is contained in:
Ignasi Marimon-Clos 2020-07-13 14:04:28 +02:00
parent 6c12ae117a
commit 6ca92cc543
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-docs/src/test/java/jdocs/stream/operators/sourceorflow/Monitor.java
View file

@ -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());
}