private boolean processBulkReply(ByteBuf in) {
        int length = lineLength();
        if (length == 0) {
            return false;
        }
        in.skipBytes(length);

        int numBytes = readInt(length - 2); // 2 == \r\n
        if (numBytes == -1) {
            return true;
        }
        
        if (in.readableBytes() < numBytes + 2) {
            return false;
        }
        
        in.skipBytes(numBytes + 2);

        return true;
    }
private boolean processBulkReply(ByteBuf in) {
        int length = lineLength();
        if (length == 0) {
            return false;
        }
        in.skipBytes(length);

        int numBytes = readInt(length - 2); 
        if (numBytes == -1) {
            return true;
        }
        
        if (in.readableBytes() < numBytes + 2) {
            return false;
        }
        
        in.skipBytes(numBytes + 2);

        return true;
    }
private boolean processBulkReply ( ByteBuf in ) { int length = lineLength ( ) ; if ( length == 0 ) { return false ; } in . skipBytes ( length ) ; int numBytes = readInt ( length - 2 ) ; // 2 == \r\n if ( numBytes == - 1 ) { return true ; } if ( in . readableBytes ( ) < numBytes + 2 ) { return false ; } in . skipBytes ( numBytes + 2 ) ; return true ; }
Process bulk reply.

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