src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/PlainTunnelingConnection.java
equal
deleted
inserted
replaced
62 .thenCompose((Void v) -> { |
62 .thenCompose((Void v) -> { |
63 debug.log(Level.DEBUG, "sending HTTP/1.1 CONNECT"); |
63 debug.log(Level.DEBUG, "sending HTTP/1.1 CONNECT"); |
64 HttpClientImpl client = client(); |
64 HttpClientImpl client = client(); |
65 assert client != null; |
65 assert client != null; |
66 HttpRequestImpl req = new HttpRequestImpl("CONNECT", address); |
66 HttpRequestImpl req = new HttpRequestImpl("CONNECT", address); |
67 MultiExchange<Void,Void> mulEx = new MultiExchange<>(req, client, discard(null), null); |
67 MultiExchange<Void,Void> mulEx = new MultiExchange<>(null, req, client, discard(null), null); |
68 Exchange<Void> connectExchange = new Exchange<>(req, mulEx); |
68 Exchange<Void> connectExchange = new Exchange<>(req, mulEx); |
69 |
69 |
70 return connectExchange |
70 return connectExchange |
71 .responseAsyncImpl(delegate) |
71 .responseAsyncImpl(delegate) |
72 .thenCompose((Response resp) -> { |
72 .thenCompose((Response resp) -> { |