diff --git a/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorServerHttpResponse.java b/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorServerHttpResponse.java index 2a98a6908c..4eedad0c2b 100644 --- a/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorServerHttpResponse.java +++ b/spring-web/src/main/java/org/springframework/http/server/reactive/ReactorServerHttpResponse.java @@ -122,7 +122,9 @@ class ReactorServerHttpResponse extends AbstractServerHttpResponse implements Ze } private Publisher toByteBufs(Publisher dataBuffers) { - return Flux.from(dataBuffers).map(NettyDataBufferFactory::toByteBuf); + return dataBuffers instanceof Mono ? + Mono.from(dataBuffers).map(NettyDataBufferFactory::toByteBuf) : + Flux.from(dataBuffers).map(NettyDataBufferFactory::toByteBuf); } }