Improve cancel handling in AbstractListenerReadPublisher

Closes gh-30393
2024-01-16 12:17:54 +00:00
parent e3f185a696
commit c4a34fa26c
3 changed files with 22 additions and 4 deletions
--- a/spring-web/src/test/java/org/springframework/http/server/reactive/ListenerReadPublisherTests.java
+++ b/spring-web/src/test/java/org/springframework/http/server/reactive/ListenerReadPublisherTests.java
@@ -104,6 +104,9 @@ class ListenerReadPublisherTests {

 		@Override
 		protected DataBuffer read() {
+			if (this.discardCalls != 0) {
+				return null;
+			}
 			this.readCalls++;
 			return mock();
 		}