api/java/src/main/java/com/navercorp/redis/cluster/connection/RedisProtocol.java
private static byte[] processBulkReply(final RedisInputStream is) {
        int len = Integer.parseInt(is.readLine());
        log.trace("[RedisProtocol] Reply bulk-reply. ${}", len);
        if (len == -1) {
            return null;
        }
        byte[] read = new byte[len];
        int offset = 0;
        while (offset < len) {
            offset += is.read(read, offset, (len - offset));
        }
        // read 2 more bytes for the command delimiter
        is.readByte();
        is.readByte();

        return read;
    }
private static byte[] processBulkReply(final RedisInputStream is) {
        int len = Integer.parseInt(is.readLine());
        log.trace("[RedisProtocol] Reply bulk-reply. ${}", len);
        if (len == -1) {
            return null;
        }
        byte[] read = new byte[len];
        int offset = 0;
        while (offset < len) {
            offset += is.read(read, offset, (len - offset));
        }
        // read 2 more bytes for the command delimiter
        is.readByte();
        is.readByte();

        return read;
    }
private static byte [ ] processBulkReply ( final RedisInputStream is ) { int len = Integer . parseInt ( is . readLine ( ) ) ; log . trace ( "[RedisProtocol] Reply bulk-reply. ${}" , len ) ; if ( len == - 1 ) { return null ; } byte [ ] read = new byte [ len ] ; int offset = 0 ; while ( offset < len ) { offset += is . read ( read , offset , ( len - offset ) ) ; } // read 2 more bytes for the command delimiter is . readByte ( ) ; is . readByte ( ) ; return read ; }
Process bulk reply.

@param is the is
@return the byte[]
Process bulk reply .