Fix fallback compression handler

2025-01-17 15:10:06 +00:00
parent c0fdf20224
commit 71feb11b2e
1 changed files with 2 additions and 1 deletions
--- a/native/src/main/java/com/velocitypowered/natives/compression/JavaVelocityCompressor.java
+++ b/native/src/main/java/com/velocitypowered/natives/compression/JavaVelocityCompressor.java
@@ -57,7 +57,8 @@ public class JavaVelocityCompressor implements VelocityCompressor {
    inflater.setInput(source.nioBuffer());

    try {
-      while (!inflater.finished() && inflater.getBytesWritten() < uncompressedSize) {
+      final int readable = source.readableBytes();
+      while (!inflater.finished() && inflater.getBytesRead() < readable) {
        if (!destination.isWritable()) {
          destination.ensureWritable(ZLIB_BUFFER_SIZE);
        }