--- a/src/java.net.http/share/classes/jdk/internal/net/http/Http1Exchange.java Wed Aug 08 15:51:08 2018 -0700
+++ b/src/java.net.http/share/classes/jdk/internal/net/http/Http1Exchange.java Thu Aug 09 11:23:12 2018 +0100
@@ -233,7 +233,8 @@
CompletableFuture<Void> connectCF;
if (!connection.connected()) {
if (debug.on()) debug.log("initiating connect async");
- connectCF = connection.connectAsync();
+ connectCF = connection.connectAsync(exchange)
+ .thenCompose(unused -> connection.finishConnect());
Throwable cancelled;
synchronized (lock) {
if ((cancelled = failed) == null) {