Skip to content

Commit 3eadeb2

Browse files
committed
minor clean up
1 parent 9b0ae0b commit 3eadeb2

File tree

4 files changed

+8
-8
lines changed

4 files changed

+8
-8
lines changed

client/src/main/java/org/asynchttpclient/netty/SimpleGenericFutureListener.java renamed to client/src/main/java/org/asynchttpclient/netty/SimpleFutureListener.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -14,9 +14,9 @@
1414
package org.asynchttpclient.netty;
1515

1616
import io.netty.util.concurrent.Future;
17-
import io.netty.util.concurrent.GenericFutureListener;
17+
import io.netty.util.concurrent.FutureListener;
1818

19-
public abstract class SimpleGenericFutureListener<V> implements GenericFutureListener<Future<V>> {
19+
public abstract class SimpleFutureListener<V> implements FutureListener<V> {
2020

2121
@Override
2222
public final void operationComplete(Future<V> future) throws Exception {

client/src/main/java/org/asynchttpclient/netty/channel/NettyConnectListener.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
import org.asynchttpclient.handler.AsyncHandlerExtensions;
2525
import org.asynchttpclient.netty.NettyResponseFuture;
2626
import org.asynchttpclient.netty.SimpleChannelFutureListener;
27-
import org.asynchttpclient.netty.SimpleGenericFutureListener;
27+
import org.asynchttpclient.netty.SimpleFutureListener;
2828
import org.asynchttpclient.netty.future.StackTraceInspector;
2929
import org.asynchttpclient.netty.request.NettyRequestSender;
3030
import org.asynchttpclient.uri.Uri;
@@ -92,7 +92,7 @@ public void onSuccess(Channel channel) throws Exception {
9292
if (asyncHandlerExtensions != null)
9393
asyncHandlerExtensions.onTlsHandshakeAttempt();
9494

95-
sslHandler.handshakeFuture().addListener(new SimpleGenericFutureListener<Channel>() {
95+
sslHandler.handshakeFuture().addListener(new SimpleFutureListener<Channel>() {
9696

9797
@Override
9898
protected void onSuccess(Channel value) throws Exception {

client/src/main/java/org/asynchttpclient/netty/request/NettyRequestSender.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@
5151
import org.asynchttpclient.handler.TransferCompletionHandler;
5252
import org.asynchttpclient.netty.Callback;
5353
import org.asynchttpclient.netty.NettyResponseFuture;
54-
import org.asynchttpclient.netty.SimpleGenericFutureListener;
54+
import org.asynchttpclient.netty.SimpleFutureListener;
5555
import org.asynchttpclient.netty.channel.ChannelManager;
5656
import org.asynchttpclient.netty.channel.ChannelState;
5757
import org.asynchttpclient.netty.channel.Channels;
@@ -275,7 +275,7 @@ private <T> ListenableFuture<T> sendRequestWithNewChannel(//
275275
}
276276

277277
RequestHostnameResolver.INSTANCE.resolve(request, proxy, asyncHandler)//
278-
.addListener(new SimpleGenericFutureListener<List<InetSocketAddress>>() {
278+
.addListener(new SimpleFutureListener<List<InetSocketAddress>>() {
279279

280280
@Override
281281
protected void onSuccess(List<InetSocketAddress> addresses) {

client/src/main/java/org/asynchttpclient/resolver/RequestHostnameResolver.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@
2525
import org.asynchttpclient.AsyncHandler;
2626
import org.asynchttpclient.Request;
2727
import org.asynchttpclient.handler.AsyncHandlerExtensions;
28-
import org.asynchttpclient.netty.SimpleGenericFutureListener;
28+
import org.asynchttpclient.netty.SimpleFutureListener;
2929
import org.asynchttpclient.proxy.ProxyServer;
3030
import org.asynchttpclient.uri.Uri;
3131

@@ -68,7 +68,7 @@ public Future<List<InetSocketAddress>> resolve(Request request, ProxyServer prox
6868
else {
6969
Promise<List<InetSocketAddress>> promise = ImmediateEventExecutor.INSTANCE.newPromise();
7070

71-
whenResolved.addListener(new SimpleGenericFutureListener<List<InetSocketAddress>>() {
71+
whenResolved.addListener(new SimpleFutureListener<List<InetSocketAddress>>() {
7272

7373
@Override
7474
protected void onSuccess(List<InetSocketAddress> addresses) throws Exception {

0 commit comments

Comments
 (0)