Tweak contentList fix

reactor · May 6, 2019 · c6aa625 · c6aa625
1 parent 8e80029
commit c6aa625
Showing 1 changed file with 15 additions and 6 deletions.
diff --git a/src/main/java/reactor/netty/http/client/HttpClientOperations.java b/src/main/java/reactor/netty/http/client/HttpClientOperations.java
@@ -355,16 +355,25 @@ && markSentHeaderAndBody()) {
 					                return FutureMono.from(channel().writeAndFlush(newFullBodyMessage(Unpooled.EMPTY_BUFFER)));
 				                }
 
-				                CompositeByteBuf agg = alloc.compositeBuffer(list.size());
+				                ByteBuf output;
+				                int i = list.size();
+				                if (i == 1) {
+				                	output = list.get(0);
+				                }
+				                else {
+					                CompositeByteBuf agg = alloc.compositeBuffer(list.size());
+
+					                for (ByteBuf component : list) {
+						                agg.addComponent(true, component);
+					                }
 
-				                for (ByteBuf component : list) {
-					                agg.addComponent(component);
+					                output = agg;
 				                }
 
-				                if (agg.readableBytes() > 0) {
-					                return FutureMono.from(channel().writeAndFlush(newFullBodyMessage(agg)));
+				                if (output.readableBytes() > 0) {
+					                return FutureMono.from(channel().writeAndFlush(newFullBodyMessage(output)));
 				                }
-				                agg.release();
+				                output.release();
 				                return FutureMono.from(channel().writeAndFlush(newFullBodyMessage(Unpooled.EMPTY_BUFFER)));
 			                }));
 		}