src/main/java/com/uber/rss/messages/ConnectDownloadRequest.java [67:80]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static ConnectDownloadRequest deserialize(ByteBuf buf) {
        String user = ByteBufUtils.readLengthAndString(buf);
        String appId = ByteBufUtils.readLengthAndString(buf);
        String appAttempt = ByteBufUtils.readLengthAndString(buf);
        int shuffleId = buf.readInt();
        int partitionId = buf.readInt();
        int numTaskAttemptIds = buf.readInt();
        List<Long> taskAttemptIds = new ArrayList<>(numTaskAttemptIds);
        for (int i = 0; i < numTaskAttemptIds; i++) {
            long taskAttemptId = buf.readLong();
            taskAttemptIds.add(taskAttemptId);
        }
        return new ConnectDownloadRequest(user, appId, appAttempt, shuffleId, partitionId, taskAttemptIds);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/messages/ConnectDownloadRequestMessage.java [71:84]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static ConnectDownloadRequest deserialize(ByteBuf buf) {
        String user = ByteBufUtils.readLengthAndString(buf);
        String appId = ByteBufUtils.readLengthAndString(buf);
        String appAttempt = ByteBufUtils.readLengthAndString(buf);
        int shuffleId = buf.readInt();
        int partitionId = buf.readInt();
        int numTaskAttemptIds = buf.readInt();
        List<Long> taskAttemptIds = new ArrayList<>(numTaskAttemptIds);
        for (int i = 0; i < numTaskAttemptIds; i++) {
            long taskAttemptId = buf.readLong();
            taskAttemptIds.add(taskAttemptId);
        }
        return new ConnectDownloadRequest(user, appId, appAttempt, shuffleId, partitionId, taskAttemptIds);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -