Я пытаюсь загрузить файлы в 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)
}
}