From 3ad765556d1d2b0543bb2a61a8fcb7ce8b47b713 Mon Sep 17 00:00:00 2001
From: Sebastien Deleuze <sdeleuze@pivotal.io>
Date: Fri, 16 Oct 2015 15:35:16 +0200
Subject: [PATCH] Polish ByteBufferPublisherInputStream exception handling

---
 .../reactive/io/ByteBufferPublisherInputStream.java          | 5 -----
 1 file changed, 5 deletions(-)

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();
 		}