public void waitForEachEventLoop ( ) throws InterruptedException , ExecutionException { for ( EventExecutor exec : serverGroup . clientToProxyWorkerPool ) { exec . submit ( ( ) -> { // Do nothing. } ) . get ( ) ; } }
This is just for use in unit - testing .