diff --git a/spring-web/src/main/java/org/springframework/http/codec/json/Jackson2JsonEncoder.java b/spring-web/src/main/java/org/springframework/http/codec/json/Jackson2JsonEncoder.java index 0b2c192373..5c97a4f97d 100644 --- a/spring-web/src/main/java/org/springframework/http/codec/json/Jackson2JsonEncoder.java +++ b/spring-web/src/main/java/org/springframework/http/codec/json/Jackson2JsonEncoder.java @@ -96,7 +96,7 @@ public class Jackson2JsonEncoder extends AbstractJackson2Codec implements Encode Mono endArray = Mono.just(bufferFactory.wrap(END_ARRAY_BUFFER)); Flux array = Flux.from(inputStream) - .flatMap(value -> { + .concatMap(value -> { DataBuffer arraySeparator = bufferFactory.wrap(SEPARATOR_BUFFER); return Flux.just(encodeValue(value, bufferFactory, elementType), arraySeparator); });