Using DataBuffer::write results in IndexOutOfBoundsException [SPR-16365]

[spring-projects-issues]

Arjen Poutsma opened SPR-16365 and commented

Using DataBuffer.write(DataBuffer[] databuffer) in a Flux.reduce aggregation result in a IndexOutOfBoundsException when running on Netty. The reason for this is that the initial buffer does not have enough capacity to contain the data of all subsequent buffers.

---

Issue Links:

• Use of CompositeByteBuf in NettyDataBuffer results in IllegalReferenceCountException [SPR-16351] #20898 Use of CompositeByteBuf in NettyDataBuffer results in IllegalReferenceCountException

Referenced from: commits 0befc60, e39bf87, 67e7c78, 384a399

[spring-projects-issues]

Arjen Poutsma commented

Fixed in 384a399 and 67e7c78.

Fixed by introducing Mono<DataBuffer> compose(Publisher<DataBuffer>). For Netty, this uses a CompositeByteBuf to compose the given data buffers into one. For the DefaultDataBuffer, this writes all data into one buffer.