Загрузить файлы в Firebase Storage RxJava2 - PullRequest
0 голосов
/ 03 января 2019

Я пытаюсь загрузить файлы в Firebase Storage с помощью RxJava2. Как мне сделать 1 метод из этих 2? Я имею в виду, как объединить эти 2 запроса?

Не умеет делать flatMap. Кто-нибудь может помочь в рефакторинге?

 private fun uploadPhotos() {
    val urisList = globalStorageViewModel.urisList

    storageRepository.uploadFiles(urisList)
            .subscribeBy(
                    onNext = { downloadFileUrl(it) },
                    onError = { onError(it) }
            ).apply {
                disposables.add(this)
            }
}
private fun downloadFileUrl(it: Pair<UploadTask.TaskSnapshot, String>) {
    storageRepository.getDownloadUrl(it.first.storage)
            .subscribeBy(
                    onSuccess = { onFileUploaded(it) }
            ).apply {
                disposables.add(this)
            }
}
...