From 382c98f9680fab9a0c2ad50de18e3385f9cba5c1 Mon Sep 17 00:00:00 2001
From: Rossen Stoyanchev <rstoyanchev@pivotal.io>
Date: Tue, 1 Dec 2015 18:19:14 -0500
Subject: [PATCH] Remove isolated use of Reactor Buffer

---
 .../http/server/servlet31/ResponseBodySubscriber.java       | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/spring-web-reactive/src/main/java/org/springframework/http/server/servlet31/ResponseBodySubscriber.java b/spring-web-reactive/src/main/java/org/springframework/http/server/servlet31/ResponseBodySubscriber.java
index 75b49a2866..a2e82bc076 100644
--- a/spring-web-reactive/src/main/java/org/springframework/http/server/servlet31/ResponseBodySubscriber.java
+++ b/spring-web-reactive/src/main/java/org/springframework/http/server/servlet31/ResponseBodySubscriber.java
@@ -25,7 +25,6 @@ import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.reactivestreams.Subscriber;
 import org.reactivestreams.Subscription;
-import reactor.io.buffer.Buffer;
 
 import org.springframework.util.Assert;
 
@@ -88,9 +87,10 @@ public class ResponseBodySubscriber implements WriteListener, Subscriber<ByteBuf
 
 		if (ready) {
 			if (this.buffer != null) {
-				output.write(new Buffer(this.buffer).asBytes());
+				byte[] bytes = new byte[this.buffer.remaining()];
+				this.buffer.get(bytes);
 				this.buffer = null;
-
+				output.write(bytes);
 				if (!subscriberComplete) {
 					this.subscription.request(1);
 				}