diff --git a/spring-web-reactive/src/main/java/org/springframework/reactive/io/ByteBufferPublisherInputStream.java b/spring-web-reactive/src/main/java/org/springframework/reactive/io/ByteBufferPublisherInputStream.java
index 13f82b1c48..647e688712 100644
--- a/spring-web-reactive/src/main/java/org/springframework/reactive/io/ByteBufferPublisherInputStream.java
+++ b/spring-web-reactive/src/main/java/org/springframework/reactive/io/ByteBufferPublisherInputStream.java
@@ -20,7 +20,6 @@ import org.reactivestreams.Publisher;
 import org.reactivestreams.Subscription;
 import org.springframework.util.Assert;
 import reactor.Publishers;
-import reactor.core.error.CancelException;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -140,10 +139,6 @@ public class ByteBufferPublisherInputStream extends InputStream {
 				return this.currentStream;
 			}
 		}
-		catch (CancelException ce) {
-			this.completed = true;
-			return null;
-		}
 		catch (InterruptedException ex) {
 			Thread.currentThread().interrupt();
 		}