Skip to content

Commit a75c2ce

Browse files
authored
Add onRequest hook
Signed-off-by: Gang Cheng <[email protected]>
1 parent 3fff3b8 commit a75c2ce

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

spring-web/src/main/java/org/springframework/http/codec/multipart/MultipartParser.java

+1
Original file line numberDiff line numberDiff line change
@@ -99,6 +99,7 @@ public static Flux<Token> parse(Flux<DataBuffer> buffers, byte[] boundary, int m
9999
return Flux.create(sink -> {
100100
MultipartParser parser = new MultipartParser(sink, boundary, maxHeadersSize, headersCharset);
101101
sink.onCancel(parser::onSinkCancel);
102+
sink.onRequest(l -> parser.requestBuffer());
102103
buffers.subscribe(parser);
103104
});
104105
}

0 commit comments

Comments
 (0)