gistfile1.java

    @Test(groups = {"standalone", "async"})
    public void asyncConnectInvalidHostFuture() throws Throwable {

        AsyncHttpClient c = new AsyncHttpClient();
        try {
            Response response = c.preparePost("http://aninvalidhost:9999/").execute(new AsyncCompletionHandlerAdapter() {
                /* @Override */
                public void onThrowable(Throwable t) {
                    t.printStackTrace();
                }
            }).get();
            assertNull(response, "Should have thrown ExecutionException");
        } catch (ExecutionException ex) {
            Throwable cause = ex.getCause();
            if (!(cause instanceof ConnectException)) {
                fail("Should have been caused by ConnectException, not by " + cause.getClass().getName());
            }
        }
    }

@test(groups = {"standalone", "async"})
public void asyncConnectInvalidHostFuture() throws Throwable {

    AsyncHttpClient c = new AsyncHttpClient();
    try {
         for (int i = 0; i <8; ++i){
            Response response = c.preparePost("http://aninvalidhost:9999/").execute(new AsyncCompletionHandlerAdapter() {
                /* @Override */
                public void onThrowable(Throwable t) {
                    t.printStackTrace();
                }
            });
           // never call get() to avoid waiting
           //.get();
       }
        assertNull(response, "Should have thrown ExecutionException");
    } catch (ExecutionException ex) {
        Throwable cause = ex.getCause();
        if (!(cause instanceof ConnectException)) {
            fail("Should have been caused by ConnectException, not by " + cause.getClass().getName());
        }
    }
}