@ -688,15 +688,13 @@ final class PartGenerator extends BaseSubscriber<MultipartParser.Token> {
@@ -688,15 +688,13 @@ final class PartGenerator extends BaseSubscriber<MultipartParser.Token> {
@Override
publicvoidonComplete(){
this.completed=true;
publicvoidpartComplete(booleanfinalPart){
Statestate=PartGenerator.this.state.get();
// writeComplete might have changed our state to IdleFileState
if(state!=this){
state.partComplete(finalPart);
state.onComplete();
}
else{
this.completed=true;
this.finalPart=finalPart;
}
}
@ -726,7 +724,7 @@ final class PartGenerator extends BaseSubscriber<MultipartParser.Token> {
@@ -726,7 +724,7 @@ final class PartGenerator extends BaseSubscriber<MultipartParser.Token> {