We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 6ac13d1 + b19059f commit f07873cCopy full SHA for f07873c
spring-web/src/main/java/org/springframework/http/client/reactive/JdkClientHttpResponse.java
@@ -67,7 +67,12 @@ private static HttpHeaders adaptHeaders(HttpResponse<Flow.Publisher<List<ByteBuf
67
private static Flux<DataBuffer> adaptBody(
68
HttpResponse<Flow.Publisher<List<ByteBuffer>>> response, DataBufferFactory bufferFactory) {
69
70
- return JdkFlowAdapter.flowPublisherToFlux(response.body())
+ Flow.Publisher<List<ByteBuffer>> body = response.body();
71
+ if (body == null) {
72
+ return Flux.empty();
73
+ }
74
+
75
+ return JdkFlowAdapter.flowPublisherToFlux(body)
76
.flatMapIterable(Function.identity())
77
.map(bufferFactory::wrap)
78
.doOnDiscard(DataBuffer.class, DataBufferUtils::release)
0 commit comments