diff --git a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/compress/CompressExtension.java b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/compress/CompressExtension.java
index 8eabd578efc0..2403d6d42e83 100644
--- a/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/compress/CompressExtension.java
+++ b/jetty-websocket/websocket-common/src/main/java/org/eclipse/jetty/websocket/common/extensions/compress/CompressExtension.java
@@ -209,13 +209,9 @@ protected void decompress(ByteAccumulator accumulator, ByteBuffer buf) throws Da
             {
                 byte[] output = accumulator.newByteArray(DECOMPRESS_BUF_SIZE);
                 read = inflater.inflate(output);
-                if (read < 0)
+                if (read <= 0)
                 {
-                    break;
-                }
-                else if (read == 0)
-                {
-                    if (LOG.isDebugEnabled())
+                    if (read == 0 && LOG.isDebugEnabled())
                         LOG.debug("Decompress: read 0 {}", toDetail(inflater));
                     break;
                 }