@ -523,7 +523,7 @@ final class MultipartParser extends BaseSubscriber<DataBuffer> {
@@ -523,7 +523,7 @@ final class MultipartParser extends BaseSubscriber<DataBuffer> {
if(logger.isTraceEnabled()){
logger.trace("Boundary found @"+endIdx+" in "+buffer);
@ -538,10 +538,11 @@ final class MultipartParser extends BaseSubscriber<DataBuffer> {
@@ -538,10 +538,11 @@ final class MultipartParser extends BaseSubscriber<DataBuffer> {
DataBufferUtils.release(boundaryBuffer);
DataBufferprev;
while((prev=this.queue.pollLast())!=null){
intprevLen=prev.readableByteCount()+len;
intprevByteCount=prev.readableByteCount();
intprevLen=prevByteCount+len;
if(prevLen>0){
// slice body part of previous buffer, and flush it
@ -550,7 +551,7 @@ final class MultipartParser extends BaseSubscriber<DataBuffer> {
@@ -550,7 +551,7 @@ final class MultipartParser extends BaseSubscriber<DataBuffer> {