equal
deleted
inserted
replaced
83 debug.log("get: HTTP/1.1: new Http1Exchange"); |
83 debug.log("get: HTTP/1.1: new Http1Exchange"); |
84 return createHttp1Exchange(exchange, connection); |
84 return createHttp1Exchange(exchange, connection); |
85 } else { |
85 } else { |
86 Http2ClientImpl c2 = exchange.client().client2(); // #### improve |
86 Http2ClientImpl c2 = exchange.client().client2(); // #### improve |
87 HttpRequestImpl request = exchange.request(); |
87 HttpRequestImpl request = exchange.request(); |
88 CompletableFuture<Http2Connection> c2f = c2.getConnectionFor(request); |
88 CompletableFuture<Http2Connection> c2f = c2.getConnectionFor(request, exchange); |
89 if (debug.on()) |
89 if (debug.on()) |
90 debug.log("get: Trying to get HTTP/2 connection"); |
90 debug.log("get: Trying to get HTTP/2 connection"); |
91 return c2f.handle((h2c, t) -> createExchangeImpl(h2c, t, exchange, connection)) |
91 return c2f.handle((h2c, t) -> createExchangeImpl(h2c, t, exchange, connection)) |
92 .thenCompose(Function.identity()); |
92 .thenCompose(Function.identity()); |
93 } |
93 } |