Невозможно обновить Circular ProgressBar при загрузке файла

Обновления пользовательского интерфейса должны происходить в потоке пользовательского интерфейса. Установка цвета из фонового потока (например, AsyncTask) фактически не обновит пользовательский интерфейс, поскольку этого не происходит в потоке пользовательского интерфейса. Есть несколько способов обновить цвет прогресса в пользовательском интерфейсе. Я бы рекомендовал иметь интерфейс вместе с функцией обратного вызова, чтобы вы могли вызывать эту функцию обратного вызова для обновления пользовательского интерфейса из активности фрагмента, который ее реализовал. Вот уточнение.

Давайте сначала объявим интерфейс.

public interface UIUpdater {
    void updateUI(int progressValue);
}

Теперь реализуйте этот интерфейс в действии или фрагменте, где вы хотите обновить пользовательский интерфейс.

public class MainActivity extends Activity implements UIUpdater {

    @Override
    public void updateUI(int progressValue) {
        // Do the UI update here. 
        circularProgress.setProgress(progressValue); // Or anything else that you want to do. 
    }
}

Вы хотите изменить конструктор инициализации вашего AsyncTask, чтобы класс UIUpdater передавался в качестве параметра.

public class YourAsyncTask extends AsyncTask<String, Void, String> {

    UIUpdater listener;

    public YourAsyncTask(UIUpdater listener) {
        this.listener = listener;
    }
}

Так что вы можете вызвать AsyncTask из действия/фрагмента, используя что-то вроде следующего.

YourAsyncTask myTask = new YourAsyncTask(this); // When you are passing this from activity, you are implicitly passing the interface that it implemented. 
myTask.execute(); 

Теперь из асинхронной задачи, пока вы публикуете прогресс, вызовите функцию прослушивателя, чтобы обновить пользовательский интерфейс, используя поток пользовательского интерфейса вашей активности/фрагмента.

protected void onProgressUpdate(Integer... values) {
    super.onProgressUpdate(values);

    try {
       listener.updateUI(values[0]);
    }
} 

Надеюсь, вы уловили идею.

Ваша проблема не в том, что вы используете RecyclerView, ваша проблема в том, что вы используете его неправильно.

Ни адаптер, ни представление (RecyclerView), ни даже ViewHolder не несут ответственности за определение чего-либо здесь.

• Я предполагаю, что у вас есть тип ViewHolder с индикатором выполнения.
• Я предполагаю, что у вас есть ListAdapter<T, K> с соответствующей реализацией DiffUtilCallback.
• Я предполагаю, что прогресс обрабатывается/сообщается в другом месте (в вашем репозитории, через модель представления или презентатор, через вариант использования, интерактор или даже обычную модель представления).
• Теперь вашему адаптеру нечего делать, кроме как ждать.
• Когда прогресс обновляется, вы подготавливаете отображаемый список, чтобы элемент, прогресс которого изменился, обновлялся.
• После этого вы отправляете этот новый список (с новым прогрессом) вашему адаптеру.
• Ваш DiffUtil вычисляет это (он тоже может быть асинхронным!)
• Ваш RecyclerView волшебным образом обновляется, не нужно ничего взламывать.

Если что-то из этого не соответствует действительности, внесите необходимые корректировки, чтобы ваш код можно было должным образом протестировать, а проблемы каждого фрагмента кода были лучше разделены.

Подумайте об этом таким образом, представьте, что у вас есть все это, и есть небольшая ошибка в значении прогресса, которое вы обновляете. Что было бы проще, искать в маленькой функции в вашей ViewModel или UseCase/interactor, которая преобразует значение Retrofit в ваш <Thing>, или повсюду в вашем спагетти-коде обратных вызовов?

Всем спасибо за попытку помочь!!

Этот ответ помог мне обновить Circular ProgressBar https://stackoverflow.com/a/42119419/11630822

public static Retrofit getDownloadRetrofit(String baseUrl, DownloadVoicemailListener listener) {

        return new Retrofit.Builder()
                .baseUrl(baseUrl)
                .addConverterFactory(GsonConverterFactory.create())
                .client(getOkHttpDownloadClientBuilder(listener).build())
                .build();

    }

    private static OkHttpClient.Builder getOkHttpDownloadClientBuilder(DownloadVoicemailListener listener) {

        OkHttpClient.Builder httpClientBuilder = new OkHttpClient.Builder().connectionSpecs(Collections.singletonList(getConnectionSpec()));

        HttpLoggingInterceptor logging = new HttpLoggingInterceptor();
        if (!releaseMode) {

            logging.level(HttpLoggingInterceptor.Level.BODY);
            httpClientBuilder.addInterceptor(logging);
        }

        httpClientBuilder.connectTimeout(20, TimeUnit.SECONDS);
        httpClientBuilder.writeTimeout(0, TimeUnit.SECONDS);
        httpClientBuilder.readTimeout(5, TimeUnit.MINUTES);

        httpClientBuilder.addInterceptor(new Interceptor() {
            @NotNull
            @Override
            public Response intercept(@NotNull Interceptor.Chain chain) throws IOException {
                if (listener == null) return chain.proceed(chain.request());

                Response originalResponse = chain.proceed(chain.request());
                return originalResponse.newBuilder()
                        .body(new ProgressResponseBody(originalResponse.body(), listener))
                        .build();
            }
        });

        return httpClientBuilder;
    }

В классе Progressbody,

public class ProgressResponseBody extends ResponseBody {
    private final String TAG=ProgressResponseBody.class.getSimpleName();
    private  ResponseBody responseBody;
    private BufferedSource bufferedSource;

    public ProgressResponseBody(ResponseBody responseBody, DownloadVoicemailListener progressListener) {
        this.responseBody = responseBody;
        progressListener.readFile(responseBody);
    }

    @Override public MediaType contentType() {
        return responseBody.contentType();
    }

    @Override public long contentLength() {
        return responseBody.contentLength();
    }

    @NotNull
    @Override public BufferedSource source() {

        if (bufferedSource == null) {
            bufferedSource = Okio.buffer(source(responseBody.source()));
        }
        return bufferedSource;

    }

    private Source source(Source source) {
        return new ForwardingSource(source) {
            long totalBytesRead = 0L;

            @Override public long read(Buffer sink, long byteCount) throws IOException {

                return byteCount;
            }
        };
    }


}

@Override
    public void readFile(ResponseBody responseBody) {
        boolean result = writeResponseBodyToDisk(responseBody);
       
    }

private boolean writeResponseBodyToDisk(ResponseBody body) {
        try {

            InputStream inputStream = null;
            OutputStream outputStream = null;

            try {
                long fileSizeDownloaded = 0;
                AndroidLogger.log(5, TAG, "File path" + filePath);
                AndroidLogger.log(5, TAG, "File size" + fileSize);
                long lengthOfFile = Long.parseLong(String.format("%.0f", Double.parseDouble(this.fileSize))) * 1024;
                AndroidLogger.log(5, TAG, "filesize" + fileSize + "length of file" + lengthOfFile);
                inputStream = body.byteStream();
                outputStream = new FileOutputStream(this.filePath);

                byte[] data = new byte[4096];
                long total = 0;
                int count;
                while ((count = inputStream.read(data)) != -1) {
                    if (cancelDownload) {
                        AndroidLogger.log(5,TAG,"Cancel download clicked");
                        inputStream.close();
                        return false;
                    }
                    total += count;
                    outputStream.write(data, 0, count);
                    fileSizeDownloaded += count;
                    if (lengthOfFile > 0) {
                        AndroidLogger.log(5, TAG, "FileSize downloaded" + fileSizeDownloaded);
                        int progress = (int) (fileSizeDownloaded * 100 / lengthOfFile);
                        AndroidLogger.log(5, TAG, "Length of  file" + lengthOfFile);
                        AndroidLogger.log(5, TAG, "Progress" + progress);
                        ((Activity) context).runOnUiThread(new Runnable() {
                            @Override
                            public void run() {
                                circularProgressBar.setProgress(progress);
                            }
                        });

                    }
                }
                AndroidLogger.log(5, TAG, "file download: " + fileSizeDownloaded + " of " + fileSize);
                outputStream.flush();
                return true;
            } catch (IOException e) {
                e.printStackTrace();
                return false;
            } finally {
                if (inputStream != null) {
                    inputStream.close();
                }

                if (outputStream != null) {
                    outputStream.close();
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
            return false;
        }
    }