Skip to content

Commit 0da63b5

Browse files
author
Rachid Ben Moussa
committed
Changed future.channel() to channel which is guarded to be non null
1 parent 2222b03 commit 0da63b5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -464,7 +464,7 @@ private void scheduleReadTimeout(NettyResponseFuture<?> nettyResponseFuture) {
464464
public void abort(Channel channel, NettyResponseFuture<?> future, Throwable t) {
465465

466466
if (channel != null) {
467-
Object attribute = Channels.getAttribute(future.channel());
467+
Object attribute = Channels.getAttribute(channel);
468468
if (attribute instanceof StreamedResponsePublisher) {
469469
((StreamedResponsePublisher) attribute).setError(t);
470470
}

0 commit comments

Comments
 (0)