api/java/src/main/java/com/navercorp/redis/cluster/connection/RedisProtocol.java
private static Object process(final RedisInputStream is) {
        byte b = is.readByte();
        if (b == MINUS_BYTE) {
            processError(is);
            return null;
        } else if (b == ASTERISK_BYTE) {
            return processMultiBulkReply(is);
        } else if (b == COLON_BYTE) {
            return processInteger(is);
        } else if (b == DOLLAR_BYTE) {
            return processBulkReply(is);
        } else if (b == PLUS_BYTE) {
            return processStatusCodeReply(is);
        } else {
            throw new JedisConnectionException("Unknown reply: " + (char) b);
        }
    }
private static Object process(final RedisInputStream is) {
        byte b = is.readByte();
        if (b == MINUS_BYTE) {
            processError(is);
            return null;
        } else if (b == ASTERISK_BYTE) {
            return processMultiBulkReply(is);
        } else if (b == COLON_BYTE) {
            return processInteger(is);
        } else if (b == DOLLAR_BYTE) {
            return processBulkReply(is);
        } else if (b == PLUS_BYTE) {
            return processStatusCodeReply(is);
        } else {
            throw new JedisConnectionException("Unknown reply: " + (char) b);
        }
    }
private static Object process ( final RedisInputStream is ) { byte b = is . readByte ( ) ; if ( b == MINUS_BYTE ) { processError ( is ) ; return null ; } else if ( b == ASTERISK_BYTE ) { return processMultiBulkReply ( is ) ; } else if ( b == COLON_BYTE ) { return processInteger ( is ) ; } else if ( b == DOLLAR_BYTE ) { return processBulkReply ( is ) ; } else if ( b == PLUS_BYTE ) { return processStatusCodeReply ( is ) ; } else { throw new JedisConnectionException ( "Unknown reply: " + ( char ) b ) ; } }
Process.

@param is the is
@return the object
Process .