equal
deleted
inserted
replaced
375 } else { |
375 } else { |
376 // send request body and proceed. |
376 // send request body and proceed. |
377 after407Check = this::sendRequestBody; |
377 after407Check = this::sendRequestBody; |
378 } |
378 } |
379 // The ProxyAuthorizationRequired can be triggered either by |
379 // The ProxyAuthorizationRequired can be triggered either by |
380 // establishExchange (case of HTTP/2 SSL tunelling through HTTP/1.1 proxy |
380 // establishExchange (case of HTTP/2 SSL tunneling through HTTP/1.1 proxy |
381 // or by sendHeaderAsync (case of HTTP/1.1 SSL tunelling through HTTP/1.1 proxy |
381 // or by sendHeaderAsync (case of HTTP/1.1 SSL tunneling through HTTP/1.1 proxy |
382 // Therefore we handle it with a call to this checkFor407(...) after these |
382 // Therefore we handle it with a call to this checkFor407(...) after these |
383 // two places. |
383 // two places. |
384 Function<ExchangeImpl<T>, CompletableFuture<Response>> afterExch407Check = |
384 Function<ExchangeImpl<T>, CompletableFuture<Response>> afterExch407Check = |
385 (ex) -> ex.sendHeadersAsync() |
385 (ex) -> ex.sendHeadersAsync() |
386 .handle((r,t) -> this.checkFor407(r, t, after407Check)) |
386 .handle((r,t) -> this.checkFor407(r, t, after407Check)) |