Skip to content

Commit 9b0bf68

Browse files
author
Stephane Landelle
committed
Timeouts weren't properly registered on the ResponseFuture
1 parent d49b86d commit 9b0bf68

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

src/main/java/com/ning/http/client/providers/netty/NettyAsyncHttpProvider.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -612,6 +612,7 @@ public void operationComplete(ChannelFuture cf) {
612612
requestTimeoutInMs, idleConnectionTimeoutInMs), idleConnectionTimeoutInMs);
613613
timeoutsHolder.idleConnectionTimeout = idleConnectionTimeout;
614614
}
615+
future.setTimeoutsHolder(timeoutsHolder);
615616

616617
} catch (RejectedExecutionException ex) {
617618
abort(future, ex);

src/main/java/com/ning/http/client/providers/netty/NettyResponseFuture.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -210,6 +210,10 @@ public boolean isIdleConnectionTimeoutReached() {
210210
return idleConnectionTimeoutReached;
211211
}
212212

213+
public void setTimeoutsHolder(TimeoutsHolder timeoutsHolder) {
214+
this.timeoutsHolder = timeoutsHolder;
215+
}
216+
213217
/**
214218
* {@inheritDoc}
215219
*/

0 commit comments

Comments
 (0)