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 package org.apache.hc.client5.http.async.methods;
28
29 import java.io.IOException;
30 import java.io.UnsupportedEncodingException;
31 import java.nio.charset.Charset;
32 import java.nio.charset.StandardCharsets;
33 import java.nio.charset.UnsupportedCharsetException;
34
35 import org.apache.hc.core5.concurrent.FutureCallback;
36 import org.apache.hc.core5.http.ContentType;
37 import org.apache.hc.core5.http.EntityDetails;
38 import org.apache.hc.core5.http.HttpException;
39 import org.apache.hc.core5.http.HttpResponse;
40 import org.apache.hc.core5.http.nio.AsyncResponseConsumer;
41 import org.apache.hc.core5.http.nio.entity.AbstractCharDataConsumer;
42 import org.apache.hc.core5.http.protocol.HttpContext;
43
44
45
46
47
48
49
50
51 public abstract class AbstractCharResponseConsumer<T> extends AbstractCharDataConsumer implements AsyncResponseConsumer<T> {
52
53 private volatile FutureCallback<T> resultCallback;
54
55
56
57
58
59
60
61
62 protected abstract void start(HttpResponse response, ContentType contentType) throws HttpException, IOException;
63
64
65
66
67
68
69 protected abstract T buildResult() throws IOException;
70
71 @Override
72 public void informationResponse(
73 final HttpResponse response,
74 final HttpContext context) throws HttpException, IOException {
75 }
76
77 @Override
78 public final void consumeResponse(
79 final HttpResponse response,
80 final EntityDetails entityDetails,
81 final HttpContext context,
82 final FutureCallback<T> resultCallback) throws HttpException, IOException {
83 this.resultCallback = resultCallback;
84 if (entityDetails != null) {
85 final ContentType contentType;
86 try {
87 contentType = ContentType.parse(entityDetails.getContentType());
88 } catch (final UnsupportedCharsetException ex) {
89 throw new UnsupportedEncodingException(ex.getMessage());
90 }
91 Charset charset = contentType != null ? contentType.getCharset() : null;
92 if (charset == null) {
93 charset = StandardCharsets.US_ASCII;
94 }
95 setCharset(charset);
96 start(response, contentType != null ? contentType : ContentType.DEFAULT_TEXT);
97 } else {
98 start(response, null);
99 completed();
100 }
101 }
102
103 @Override
104 protected final void completed() throws IOException {
105 resultCallback.completed(buildResult());
106 }
107
108 @Override
109 public void failed(final Exception cause) {
110 }
111
112 }