refactor(codec): remove intermediate byte array in ByteArrayInputStre… (#324)

…amCodec

Signed-off-by: jchrys <jchrys@me.com>

Author: jchrys

r2dbc-mysql/src/main/java/io/asyncer/r2dbc/mysql/codec/ByteArrayInputStreamCodec.java

@@ -86,16 +86,13 @@ public Mono<ByteBuf> publishBinary(ByteBufAllocator allocator) {
 
                 try {
                     VarIntUtils.writeVarInt(buf, size);
-
-                    byte[] byteArray = new byte[size];
-                    int readBytes = value.read(byteArray);
-
+                    int readBytes = buf.writeBytes(value, size);
                     if (readBytes != size) {
                         buf.release();
                         throw new IllegalStateException("Expected to read " + size + " bytes, but got " + readBytes);
                     }
 
-                    return buf.writeBytes(byteArray);
+                    return buf;
                 } catch (Exception e) {
                     buf.release();
                     throw new RuntimeException(e);