AndroidAsyncTest/src/com/koushikdutta/async/test/Issue59.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

package com.koushikdutta.async.test;

import android.util.Log;

import com.koushikdutta.async.AsyncServer;
import com.koushikdutta.async.Util;
import com.koushikdutta.async.callback.CompletedCallback;
import com.koushikdutta.async.http.AsyncHttpClient;
import com.koushikdutta.async.http.AsyncHttpGet;
import com.koushikdutta.async.http.server.AsyncHttpServer;
import com.koushikdutta.async.http.server.AsyncHttpServerRequest;
import com.koushikdutta.async.http.server.AsyncHttpServerResponse;
import com.koushikdutta.async.http.server.HttpServerRequestCallback;

import junit.framework.TestCase;

import java.util.concurrent.TimeUnit;

/**
 * Created by koush on 8/31/13.
 */
public class Issue59 extends TestCase {
    public void testIssue() throws Exception {
        try {
            AsyncHttpServer httpServer = new AsyncHttpServer();
            httpServer.get("/", new HttpServerRequestCallback() {
                @Override
                public void onRequest(AsyncHttpServerRequest request, final AsyncHttpServerResponse response) {
                    response.getHeaders().getHeaders().set("Transfer-Encoding", "");
                    response.responseCode(200);
                    Util.writeAll(response, "foobarbeepboop".getBytes(), new CompletedCallback() {
                        @Override
                        public void onCompleted(Exception ex) {
                            response.close();
                        }
                    });
                }
            });

            httpServer.listen(5959);

            AsyncHttpGet get = new AsyncHttpGet("http://localhost:5959/");
            get.setLogging("issue59", Log.VERBOSE);
            get.getHeaders().getHeaders().removeAll("Connection");
            get.getHeaders().getHeaders().removeAll("Accept-Encoding");

            assertEquals("foobarbeepboop", AsyncHttpClient.getDefaultInstance().executeString(get).get(1000, TimeUnit.MILLISECONDS));
        }
        finally {
            AsyncServer.getDefault().stop();
        }
    }
}