ByteBody-based response handling for the HTTP client

http-client-core/src/main/java/io/micronaut/http/client/exceptions/ContentLengthExceededException.java

@@ -15,6 +15,8 @@
  */
 package io.micronaut.http.client.exceptions;
 
+import io.micronaut.core.annotation.Internal;
+
 /**
  * @author Graeme Rocher
  * @since 1.0
@@ -35,4 +37,15 @@ public ContentLengthExceededException(long maxLength, long receivedLength) {
     public ContentLengthExceededException(long maxLength) {
         super("The received length exceeds the maximum allowed content length [" + maxLength + "]");
     }
+
+    /**
+     * Constructor with a message, useful for adapting from
+     * {@link io.micronaut.http.exceptions.ContentLengthExceededException}.
+     *
+     * @param message The message
+     */
+    @Internal
+    public ContentLengthExceededException(String message) {
+        super(message);
+    }
 }

http-client/src/main/java/io/micronaut/http/client/netty/FullNettyClientHttpResponse.java

@@ -87,9 +87,7 @@ public class FullNettyClientHttpResponse<B> implements HttpResponse<B>, NettyHtt
         this.nettyHttpResponse = fullHttpResponse;
         // this class doesn't really have lifecycle management (we don't make the user release()
         // it), so we have to copy the data to a non-refcounted buffer.
-        ByteBuf buffer = Unpooled.buffer(fullHttpResponse.content().readableBytes());
-        buffer.writeBytes(fullHttpResponse.content(), 0, fullHttpResponse.content().readableBytes());
-        this.unpooledContent = Unpooled.unreleasableBuffer(buffer);
+        this.unpooledContent = Unpooled.unreleasableBuffer(Unpooled.copiedBuffer(fullHttpResponse.content()));
         this.handlerRegistry = handlerRegistry;
         this.nettyCookies = new NettyCookies(fullHttpResponse.headers(), conversionService);
         Class<?> rawBodyType = bodyType != null ? bodyType.getType() : null;