flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/akka/AkkaRpcServiceTest.java
/**
	 * Tests that we can wait for the termination of the rpc service
	 *
	 * @throws ExecutionException
	 * @throws InterruptedException
	 */
Tests that we can wait for the termination of the rpc service
@throws ExecutionException
@throws InterruptedException
Tests that we can wait for the termination of the rpc service @throws ExecutionException @throws InterruptedException
@Test(timeout = 60000)
	public void testTerminationFuture() throws ExecutionException, InterruptedException {
		final ActorSystem actorSystem = AkkaUtils.createDefaultActorSystem();
		final AkkaRpcService rpcService = new AkkaRpcService(actorSystem, Time.milliseconds(1000));
		CompletableFuture<Void> terminationFuture = rpcService.getTerminationFuture();
		assertFalse(terminationFuture.isDone());
		CompletableFuture.runAsync(() -> rpcService.stopService(), actorSystem.dispatcher());
		terminationFuture.get();
	}
@ Test ( timeout = 60000 ) public void testTerminationFuture ( ) throws ExecutionException , InterruptedException { final ActorSystem actorSystem = AkkaUtils . createDefaultActorSystem ( ) ; final AkkaRpcService rpcService = new AkkaRpcService ( actorSystem , Time . milliseconds ( 1000 ) ) ; CompletableFuture < Void > terminationFuture = rpcService . getTerminationFuture ( ) ; assertFalse ( terminationFuture . isDone ( ) ) ; CompletableFuture . runAsync ( ( ) -> rpcService . stopService ( ) , actorSystem . dispatcher ( ) ) ; terminationFuture . get ( ) ; }
Tests that we can wait for the termination of the rpc service
 @throws ExecutionException
 @throws InterruptedException
Tests that we can wait for the termination of the rpc service @throws ExecutionException @throws InterruptedException