|
|
|
@ -120,7 +120,7 @@ public class JettyClientHttpConnector implements ClientHttpConnector { |
|
|
|
Request request = this.httpClient.newRequest(uri).method(method.toString()); |
|
|
|
Request request = this.httpClient.newRequest(uri).method(method.toString()); |
|
|
|
|
|
|
|
|
|
|
|
return requestCallback.apply(new JettyClientHttpRequest(request, this.bufferFactory)) |
|
|
|
return requestCallback.apply(new JettyClientHttpRequest(request, this.bufferFactory)) |
|
|
|
.then(Mono.from(ReactiveRequest.newBuilder(request).build() |
|
|
|
.then(Mono.fromDirect(ReactiveRequest.newBuilder(request).build() |
|
|
|
.response((reactiveResponse, chunkPublisher) -> { |
|
|
|
.response((reactiveResponse, chunkPublisher) -> { |
|
|
|
Flux<DataBuffer> content = Flux.from(chunkPublisher).map(this::toDataBuffer); |
|
|
|
Flux<DataBuffer> content = Flux.from(chunkPublisher).map(this::toDataBuffer); |
|
|
|
return Mono.just(new JettyClientHttpResponse(reactiveResponse, content)); |
|
|
|
return Mono.just(new JettyClientHttpResponse(reactiveResponse, content)); |
|
|
|
|