Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed DataBufferUtils.takeUntilByteCount

Browse Source
This commit is contained in:
Arjen Poutsma
2016-04-22 13:01:18 +02:00
parent 52c9b3b235
commit 9ed4bff4a9
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-web-reactive/src/main/java/org/springframework/core/io/buffer/support/DataBufferUtils.java
View File

@@ -139,10 +139,10 @@ public abstract class DataBufferUtils {
@Override
public void onNext(DataBuffer dataBuffer) {
long currentCount =
this.byteCount.addAndGet(dataBuffer.readableByteCount());
int delta = dataBuffer.readableByteCount();
long currentCount = this.byteCount.addAndGet(delta);
if (currentCount > maxByteCount) {
int size = (int) (currentCount - maxByteCount + 1);
int size = (int) (maxByteCount - currentCount + delta);
ByteBuffer byteBuffer =
(ByteBuffer) dataBuffer.asByteBuffer().limit(size);
DataBuffer partialBuffer =