@@ -330,54 +330,13 @@ public String onCompleted() throws Exception {
330
330
}
331
331
}
332
332
333
- @ Test (groups = { "online" , "default_provider" })
334
- public void asyncStream302WithBody () throws Exception {
335
- AsyncHttpClient client = getAsyncHttpClient (null );
336
- final AtomicReference <Integer > statusCode = new AtomicReference <Integer >(0 );
337
- final AtomicReference <FluentCaseInsensitiveStringsMap > headers = new AtomicReference <FluentCaseInsensitiveStringsMap >();
338
- try {
339
- Future <String > f = client .prepareGet ("http://google.com/" ).execute (new AsyncHandlerAdapter () {
340
-
341
- public STATE onStatusReceived (HttpResponseStatus status ) throws Exception {
342
- statusCode .set (status .getStatusCode ());
343
- return STATE .CONTINUE ;
344
- }
345
-
346
- @ Override
347
- public STATE onHeadersReceived (HttpResponseHeaders content ) throws Exception {
348
- headers .set (content .getHeaders ());
349
- return STATE .CONTINUE ;
350
- }
351
-
352
- @ Override
353
- public STATE onBodyPartReceived (HttpResponseBodyPart content ) throws Exception {
354
- return STATE .CONTINUE ;
355
- }
356
-
357
- @ Override
358
- public String onCompleted () throws Exception {
359
- return null ;
360
- }
361
- });
362
-
363
- f .get (20 , TimeUnit .SECONDS );
364
- assertEquals (statusCode .get ().intValue (), 302 );
365
- FluentCaseInsensitiveStringsMap h = headers .get ();
366
- assertNotNull (h );
367
- assertEquals (h .getJoinedValue ("content-type" , ", " ).toLowerCase (Locale .ENGLISH ), TEXT_HTML_CONTENT_TYPE_WITH_UTF_8_CHARSET .toLowerCase (Locale .ENGLISH ));
368
-
369
- } finally {
370
- client .close ();
371
- }
372
- }
373
-
374
333
@ Test (groups = { "online" , "default_provider" })
375
334
public void asyncStream302RedirectWithBody () throws Exception {
376
335
AsyncHttpClient client = getAsyncHttpClient (new AsyncHttpClientConfig .Builder ().setFollowRedirect (true ).build ());
377
336
final AtomicReference <Integer > statusCode = new AtomicReference <Integer >(0 );
378
337
final AtomicReference <FluentCaseInsensitiveStringsMap > responseHeaders = new AtomicReference <FluentCaseInsensitiveStringsMap >();
379
338
try {
380
- Future <String > f = client .prepareGet ("http://google.com/ " ).execute (new AsyncHandlerAdapter () {
339
+ Future <String > f = client .prepareGet ("http://google.com/" ).execute (new AsyncHandlerAdapter () {
381
340
382
341
public STATE onStatusReceived (HttpResponseStatus status ) throws Exception {
383
342
statusCode .set (status .getStatusCode ());
0 commit comments