From a75c2ce2ac6a56a721a0b8bac846cc7c3d00c495 Mon Sep 17 00:00:00 2001
From: Gang Cheng <chenggangpro@gmail.com>
Date: Sat, 8 Feb 2025 12:01:25 +0800
Subject: [PATCH] Add onRequest hook

Signed-off-by: Gang Cheng <chenggangpro@gmail.com>
---
 .../springframework/http/codec/multipart/MultipartParser.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/spring-web/src/main/java/org/springframework/http/codec/multipart/MultipartParser.java b/spring-web/src/main/java/org/springframework/http/codec/multipart/MultipartParser.java
index 7b093e103742..b1fa77f287c6 100644
--- a/spring-web/src/main/java/org/springframework/http/codec/multipart/MultipartParser.java
+++ b/spring-web/src/main/java/org/springframework/http/codec/multipart/MultipartParser.java
@@ -99,6 +99,7 @@ public static Flux<Token> parse(Flux<DataBuffer> buffers, byte[] boundary, int m
 		return Flux.create(sink -> {
 			MultipartParser parser = new MultipartParser(sink, boundary, maxHeadersSize, headersCharset);
 			sink.onCancel(parser::onSinkCancel);
+			sink.onRequest(l -> parser.requestBuffer());
 			buffers.subscribe(parser);
 		});
 	}