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

Use getWhenTerminated in Java examples (#24428)

Browse source 
* Use getWhenTerminated in Java examples

Introduced in #24330

* Fix compilation error
This commit is contained in:
Arnout Engelen 2018-01-29 10:05:11 +01:00 • committed by Konrad `ktoso` Malawski
parent 0e2d001cce
commit c05dd26700
3 changed files with 5 additions and 10 deletions
Download patch file Download diff file Expand all files Collapse all files

8
akka-actor-typed-tests/src/test/java/jdocs/akka/typed/GracefulStopDocTest.java
View file

@ -5,14 +5,12 @@ package jdocs.akka.typed;
//#imports
import java.util.concurrent.TimeUnit;
import akka.actor.typed.ActorSystem;
import akka.actor.typed.Behavior;
import akka.actor.typed.PostStop;
import akka.actor.typed.javadsl.Behaviors;
import scala.concurrent.Await;
import scala.concurrent.duration.Duration;
import java.util.concurrent.TimeUnit;
//#imports
@ -85,7 +83,7 @@ public class GracefulStopDocTest {
system.tell(new JobControl.GracefulShutdown());
Await.result(system.whenTerminated(), Duration.create(3, TimeUnit.SECONDS));
system.getWhenTerminated().toCompletableFuture().get(3, TimeUnit.SECONDS);
//#graceful-shutdown
}

4
akka-actor-typed-tests/src/test/java/jdocs/akka/typed/IntroTest.java
View file

@ -19,8 +19,6 @@ import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.TimeUnit;
import scala.concurrent.Await;
import scala.concurrent.duration.Duration;
public class IntroTest {
@ -230,7 +228,7 @@ public class IntroTest {
final ActorSystem<Void> system =
ActorSystem.create(main, "ChatRoomDemo");
Await.result(system.whenTerminated(), Duration.create(3, TimeUnit.SECONDS));
system.getWhenTerminated().toCompletableFuture().get();
//#chatroom-main
}

3
akka-docs/src/test/java/jdocs/cluster/FactorialFrontendMain.java
View file

@ -1,6 +1,5 @@
package jdocs.cluster;
import java.util.concurrent.TimeUnit;
import scala.concurrent.Await;
import scala.concurrent.duration.Duration;
@ -55,7 +54,7 @@ public class FactorialFrontendMain {
new Thread() {
@Override public void run(){
try {
Await.ready(system.whenTerminated(), Duration.create(10, TimeUnit.SECONDS));
system.getWhenTerminated().toCompletableFuture().get(10, TimeUnit.SECONDS);
} catch (Exception e) {
System.exit(-1);
}