Как загрузить файлы с сервера по очереди

@Astend · Регистрация: 20.07.2014

Author24 — интернет-сервис помощи студентам

Как реализовать загрузку файлов по очереди?

Язык Kotlin:

Java

class PreviewPresenterImpl
    @Inject constructor(view: PreviewView,
                        private val interactor: HistoryInteractor,
                        private var disposable: CompositeDisposable = CompositeDisposable())
    : BasePresenter<PreviewView>(view)
 
    override fun loadFiles(originalPathways: ArrayList<String>) {
        for (fileUrl in originalPathways) {
            disposable.add(interactor.downloadFile(fileUrl)
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribeOn(Schedulers.io())
                    .flatMap(this::saveFile)
                    .subscribe(
                            { file -> files.add(file.absolutePath) },
                            { error -> Log.e("TAG", "{$error.message}") },
                            { Log.d("TAG", "completed") })
            )
        }
 
        view.onFilesLoadedComplete(files)
    }

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

код рабочий, проблема в том что цикл закачивается раньше чем завершатся загрузка (что как бы логично), соответственно метод оно то вызвало, а толку от этого никакого.

@ExFau$t · 22.11.2018, 23:42

Почему бы не сделать всю загрузку в одном потоке, а потом уже в onComplete/onSuccess вызвать какой-то там метод?

@Astend · 23.11.2018, 00:05 **[ТС]**

пхаха)) так в этом и вопрос, как сделать загрузку в одном потоке?

@ExFau$t · 23.11.2018, 09:09

Например так:

Java

1	.flatMapPublisher(Flowable::fromIterable)

@Astend · 23.11.2018, 13:20 **[ТС]**

ExFau$t, не понимаю куда нужно это добавить.

@ExFau$t · 23.11.2018, 18:03

Нужно создать поток, подать на вход список, метод выше пробегает этот список. Типо такого:

Java

1 2	Single.just(originalPathways) .flatMapPublisher(Flowable::fromIterable)

Дальше уже твой запрос, но метод view.onFilesLoadedComplete(files) должен быть вызван по окончании потока, то бишь в onComplete/onSuccess/onNext.

@ExFau$t 1570 / 1168 / 426 Регистрация: 08.05.2012 Сообщений: 5,219
	22.11.2018, 23:42	2
	Почему бы не сделать всю загрузку в одном потоке, а потом уже в onComplete/onSuccess вызвать какой-то там метод? 0

@Astend 5 / 5 / 5 Регистрация: 20.07.2014 Сообщений: 215
	23.11.2018, 00:05 [ТС]	3
	пхаха)) так в этом и вопрос, как сделать загрузку в одном потоке? 0

@Astend 5 / 5 / 5 Регистрация: 20.07.2014 Сообщений: 215
	23.11.2018, 13:20 [ТС]	5
	ExFau$t, не понимаю куда нужно это добавить. 0

	23.11.2018, 18:03