1

Я пытаюсь создать Observable, который загружает файл 10 раз через секунду и отдает результат в Subscriber. Однако, Observable загружает файл единожды. Вот код:

        Observable.create((subscriber) -> {
            Log.i(TAG, "Загрузка начинается");
            mDownloadHelper.downloadFile(
                    mSharedPreferences.getString(DOC_URL_KEY, ""),
                    Environment.DIRECTORY_DOWNLOADS,
                    new DownloadHelper.DownloadListener() {
                        @Override
                        public void onDownloaded(Uri fileUri) {
                            subscriber.onNext(fileUri);
                        }

                        @Override
                        public void onFailed() {
                            subscriber.onError(new Exception("Не выходит загрузить файл"));
                        }
                    });

            Log.i(TAG, "Загрузка началась");
        })
                .repeat(10)
                .delay(1, TimeUnit.SECONDS)
                .observeOn(Schedulers.io())
                .subscribeOn(Schedulers.io())
                .subscribe(new Subscriber<Object>() {
                    @Override
                    public void onNext(Object o) {
                        Log.i(TAG, "Загрузился!");
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.i(TAG, "Ошибка!");
                    }

                    @Override
                    public void onCompleted() {
                        Log.i(TAG, "Завершился"); //Не должно быть
                    }
                });

В результате вывод лог такой:

10-23 15:04:24.744 24859-24886/com.dugin.rostislav.reminderofwork.doc_handling_service I/RLOG: Загрузка начинается
10-23 15:04:24.866 24859-24886/com.dugin.rostislav.reminderofwork.doc_handling_service I/RLOG: Загрузка началась
10-23 15:04:26.515 24859-24888/com.dugin.rostislav.reminderofwork.doc_handling_service I/RLOG: Загрузился!

В чем проблема и как ее исправить?

1 ответ 1

2

Возможно, повтора не будет пока задача не завершится. Т.е. попробуйте после скачивания файла вызвать

subscriber.onCompleted();
7
  • Не является ответом на вопрос. Чтобы оставить свои замечания или попросить у автора внести уточнения, оставьте комментарий к соответствующему сообщению. - Из очереди проверок 23 окт 2016 в 14:43
  • О, Юрий! А вы все еще тут обитаете? :)
    – user189127
    23 окт 2016 в 15:08
  • @AntonShchyrov, как показала практика это вполне себе ответ. Просто он не всегда должен быть длинным и полным уверенности в своей правильности)
    – ЮрийСПб
    23 окт 2016 в 15:27
  • @bukashka101, ну да... Это вы куда-то пропали)
    – ЮрийСПб
    23 окт 2016 в 15:27
  • @ЮрийСПб, сначала пошел читать тех. литературу (дочитал философию, Effective Java, Совершенный код и т.д.), а потом пошел писать свой проект.
    – user189127
    23 окт 2016 в 15:58

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки