Optimisation: Don't use Unpooled

src/main/java/com/github/puregero/minecraftstresstest/CompressionDecoder.java

···
 package com.github.puregero.minecraftstresstest;
 
 import io.netty.buffer.ByteBuf;
-import io.netty.buffer.Unpooled;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.ByteToMessageDecoder;
 
+import java.nio.ByteBuffer;
 import java.util.List;
 import java.util.zip.Inflater;
 
···
                 return;
             }
 
-            byte[] bs = new byte[friendlyByteBuf.readableBytes()];
-            friendlyByteBuf.readBytes(bs);
+            ByteBuffer bs;
+            if (friendlyByteBuf.nioBufferCount() > 0) {
+                bs = friendlyByteBuf.nioBuffer();
+                friendlyByteBuf.skipBytes(friendlyByteBuf.readableBytes());
+            } else {
+                bs = ByteBuffer.allocateDirect(friendlyByteBuf.readableBytes());
+                friendlyByteBuf.readBytes(bs);
+                bs.flip();
+            }
             this.inflater.setInput(bs);
-            byte[] cs = new byte[length];
-            this.inflater.inflate(cs);
-            list.add(Unpooled.wrappedBuffer(cs));
+
+            ByteBuf cs = channelHandlerContext.alloc().directBuffer(length);
+            ByteBuffer csInternal = cs.internalNioBuffer(0, length);
+            int startPos = csInternal.position();
+            this.inflater.inflate(csInternal);
+            int csLength = csInternal.position() - startPos;
+            if (csLength != length) {
+                throw new IllegalStateException("Decompressed length " + csLength + " does not match expected length " + length);
+            }
+            cs.writerIndex(cs.writerIndex() + csLength);
+
             this.inflater.reset();
+            list.add(cs);
         }
     }
 }

src/main/java/com/github/puregero/minecraftstresstest/PacketDecoder.java

···
 package com.github.puregero.minecraftstresstest;
 
 import io.netty.buffer.ByteBuf;
-import io.netty.buffer.Unpooled;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.handler.codec.ByteToMessageDecoder;
 
···
                 return;
             }
 
-            byte[] bs = new byte[length];
-            friendlyByteBuf.readBytes(bs);
-            list.add(Unpooled.wrappedBuffer(bs));
+            list.add(friendlyByteBuf.readBytes(length));
         }
     }
 }