|
15 | 15 |
|
16 | 16 | import static com.ning.http.util.MiscUtil.isNonEmpty;
|
17 | 17 |
|
18 |
| -import com.ning.http.client.AsyncHttpClient; |
19 |
| -import com.ning.http.client.Part; |
| 18 | +import com.ning.http.client.*; |
20 | 19 | import com.ning.http.multipart.MultipartBody;
|
21 | 20 | import com.ning.org.jboss.netty.handler.codec.http.CookieDecoder;
|
22 |
| -import com.ning.http.client.AsyncHandler; |
23 |
| -import com.ning.http.client.AsyncHttpClientConfig; |
24 |
| -import com.ning.http.client.AsyncHttpProvider; |
25 |
| -import com.ning.http.client.AsyncHttpProviderConfig; |
26 |
| -import com.ning.http.client.Body; |
27 |
| -import com.ning.http.client.BodyGenerator; |
28 |
| -import com.ning.http.client.ConnectionsPool; |
29 |
| -import com.ning.http.client.Cookie; |
30 |
| -import com.ning.http.client.FluentCaseInsensitiveStringsMap; |
31 |
| -import com.ning.http.client.FluentStringsMap; |
32 |
| -import com.ning.http.client.HttpResponseBodyPart; |
33 |
| -import com.ning.http.client.HttpResponseHeaders; |
34 |
| -import com.ning.http.client.HttpResponseStatus; |
35 |
| -import com.ning.http.client.ListenableFuture; |
36 |
| -import com.ning.http.client.MaxRedirectException; |
37 |
| -import com.ning.http.client.PerRequestConfig; |
38 |
| -import com.ning.http.client.ProxyServer; |
39 |
| -import com.ning.http.client.Realm; |
40 |
| -import com.ning.http.client.Request; |
41 |
| -import com.ning.http.client.RequestBuilder; |
42 |
| -import com.ning.http.client.Response; |
43 |
| -import com.ning.http.client.UpgradeHandler; |
44 | 21 | import com.ning.http.client.filter.FilterContext;
|
45 | 22 | import com.ning.http.client.filter.ResponseFilter;
|
46 | 23 | import com.ning.http.client.listener.TransferCompletionHandler;
|
@@ -1112,6 +1089,9 @@ protected void onHttpHeadersEncoded(HttpHeader httpHeader, FilterChainContext ct
|
1112 | 1089 | if (handler instanceof TransferCompletionHandler) {
|
1113 | 1090 | ((TransferCompletionHandler) handler).onHeaderWriteCompleted();
|
1114 | 1091 | }
|
| 1092 | + if (handler instanceof AsyncHandlerExtensions) { |
| 1093 | + ((AsyncHandlerExtensions) handler).onRequestSent(); |
| 1094 | + } |
1115 | 1095 | }
|
1116 | 1096 |
|
1117 | 1097 | @Override
|
|
0 commit comments