File tree Expand file tree Collapse file tree 2 files changed +10
-7
lines changed
main/java/org/asynchttpclient
test/java/org/asynchttpclient/async/util Expand file tree Collapse file tree 2 files changed +10
-7
lines changed Original file line number Diff line number Diff line change 1212 */
1313package org .asynchttpclient ;
1414
15+ import java .net .InetSocketAddress ;
16+
1517/**
1618 * This interface hosts new low level callback methods on {@link AsyncHandler}.
1719 * For now, those methods are in a dedicated interface in order not to break the existing API,
@@ -63,5 +65,5 @@ public interface AsyncHandlerExtensions {
6365 /**
6466 * Notify the callback after DNS resolution has completed.
6567 */
66- void onDnsResolved (java . net . InetSocketAddress remoteAddress );
68+ void onDnsResolved (InetSocketAddress remoteAddress );
6769}
Original file line number Diff line number Diff line change 1212 */
1313package org .asynchttpclient .async .util ;
1414
15+ import java .net .InetSocketAddress ;
16+ import java .util .Queue ;
17+ import java .util .concurrent .ConcurrentLinkedQueue ;
18+ import java .util .concurrent .CountDownLatch ;
19+ import java .util .concurrent .TimeUnit ;
20+
1521import org .asynchttpclient .AsyncCompletionHandlerBase ;
1622import org .asynchttpclient .AsyncHandlerExtensions ;
1723import org .asynchttpclient .HttpResponseHeaders ;
1824import org .asynchttpclient .HttpResponseStatus ;
1925import org .asynchttpclient .Response ;
2026import org .testng .Assert ;
2127
22- import java .util .Queue ;
23- import java .util .concurrent .ConcurrentLinkedQueue ;
24- import java .util .concurrent .CountDownLatch ;
25- import java .util .concurrent .TimeUnit ;
26-
2728public class EventCollectingHandler extends AsyncCompletionHandlerBase implements AsyncHandlerExtensions {
2829 public Queue <String > firedEvents = new ConcurrentLinkedQueue <String >();
2930 private CountDownLatch completionLatch = new CountDownLatch (1 );
@@ -99,7 +100,7 @@ public void onRetry() {
99100 }
100101
101102 @ Override
102- public void onDnsResolved (java . net . InetSocketAddress remoteAddress ) {
103+ public void onDnsResolved (InetSocketAddress remoteAddress ) {
103104 firedEvents .add ("DnsResolved" );
104105 }
105106}
You can’t perform that action at this time.
0 commit comments