Better handling of TCP fragmentation.

Author: codebutler

src/com/codebutler/android_websockets/HybiParser.java

@@ -351,9 +351,21 @@ public HappyDataInputStream(InputStream in) {
 
         public byte[] readBytes(int length) throws IOException {
             byte[] buffer = new byte[length];
-            if (read(buffer) != length) {
-                throw new IOException("Read wrong number of bytes.");
+
+            int total = 0;
+
+            while (total < length) {
+                int count = read(buffer, total, length - total);
+                if (count == -1) {
+                    break;
+                }
+                total += count;
             }
+
+            if (total != length) {
+                throw new IOException(String.format("Read wrong number of bytes. Got: %s, Expected: %s.", total, length));
+            }
+
             return buffer;
         }
     }