< prev index next >

src/java.net.http/share/classes/jdk/internal/net/http/Http1Exchange.java

Print this page

        

*** 231,241 **** if (debug.on()) debug.log("response created in advance"); CompletableFuture<Void> connectCF; if (!connection.connected()) { if (debug.on()) debug.log("initiating connect async"); ! connectCF = connection.connectAsync(); Throwable cancelled; synchronized (lock) { if ((cancelled = failed) == null) { operations.add(connectCF); } --- 231,242 ---- if (debug.on()) debug.log("response created in advance"); CompletableFuture<Void> connectCF; if (!connection.connected()) { if (debug.on()) debug.log("initiating connect async"); ! connectCF = connection.connectAsync(exchange) ! .thenCompose(unused -> connection.finishConnect()); Throwable cancelled; synchronized (lock) { if ((cancelled = failed) == null) { operations.add(connectCF); }
< prev index next >