ByteBuffer tempBuffer = ByteBuffer.allocate(bytesToRead);

            int totalRead = 0;
            while (tempBuffer.hasRemaining() && totalRead < bytesToRead) {
                int read = socketChannel.read(tempBuffer);
                if (read < 0) {
                    break;
                }
                totalRead += read;
            }

            tempBuffer.flip();

        // Read all data
        byte[] buffer = new byte[size];
        int totalRead = 0;
        while (totalRead < size) {
            int read = sis.read(buffer, totalRead, size - totalRead);
            if (read == -1)
                break;
            totalRead += read;
        }

        assertEquals(size, totalRead);
        assertArrayEquals(data, buffer);
    }

    @Test

        data[1] = 0x00;
        data[2] = 0x00;
        data[3] = 0x0A; // Length = 10

        ByteArrayInputStream bais = new ByteArrayInputStream(data);

        int totalRead = packet.readWireFormat(bais, data, 0);

        assertEquals(14, totalRead); // 4 header + 10 trailer
        assertEquals(0x85, packet.type);
        assertEquals(10, packet.length);
    }

    @Test