@@ -0,0 +1,1437 @@
+package com.wizzardo.http;%0A%0Aimport org.junit.Assert;%0Aimport org.junit.Test;%0A%0Aimport java.io.IOException;%0Aimport java.util.concurrent.BlockingQueue;%0Aimport java.util.concurrent.LinkedBlockingQueue;%0A%0A/**%0A * Created by wizzardo on 07.06.15.%0A */%0Apublic class AsyncTest extends ServerTest %7B%0A%0A    @Test%0A    public void test_1() throws IOException %7B%0A        BlockingQueue%3CRunnable%3E queue = new LinkedBlockingQueue%3C%3E();%0A        new Worker%3CRunnable%3E(queue) %7B%0A            @Override%0A            protected void process(Runnable runnable) %7B%0A                runnable.run();%0A            %7D%0A        %7D.start();%0A%0A%0A        handler = new UrlHandler()%0A                .append(%22/async%22, (request, response) -%3E %7B%0A                    response.async();%0A                    queue.add(() -%3E %7B%0A                        try %7B%0A                            Thread.sleep(100);%0A                        %7D catch (InterruptedException ignored) %7B%0A                        %7D%0A                        response.setBody(%22ok%22);%0A                        response.commit(request.connection());%0A                        request.connection().onFinishingHandling();%0A                    %7D);%0A                    return response;%0A                %7D)%0A        ;%0A%0A%0A        Assert.assertEquals(%22ok%22, makeRequest(%22/async%22).get().asString());%0A        Assert.assertEquals(%22ok%22, makeRequest(%22/async%22).get().asString());%0A        Assert.assertEquals(%22ok%22, makeRequest(%22/async%22).get().asString());%0A    %7D%0A%7D%0A

add small async test