diff --git a/src/main/java/redis/clients/jedis/Protocol.java b/src/main/java/redis/clients/jedis/Protocol.java index ff96e8b..3c1ff30 100644 --- a/src/main/java/redis/clients/jedis/Protocol.java +++ b/src/main/java/redis/clients/jedis/Protocol.java @@ -139,8 +139,11 @@ public class Protocol { return null; } byte[] read = new byte[len]; + int offset = 0; try { - is.read(read); + while(offset < len) { + offset += is.read(read, offset, (len - offset)); + } // read 2 more bytes for the command delimiter is.read(); is.read();