Как правильно объединить несколько запросов с rxjava2? - PullRequest
Новая
       13

Как правильно объединить несколько запросов с rxjava2?

0 голосов
/ 18 февраля 2019

Возможно ли с помощью rxjava2 добиться последовательности, описанной ниже?У меня есть классы, такие как: 

class Holder {
    List<Image> images;
}
class Image {
    String url;
    String localFileUrl;
}

Мне нужна последовательность, как: 

* Iterate over Holders;
  * For each Holder iterate over Images;
    * Working with each images(decode Bitmap from localFileUrl and upload 
     bitmap to network -> get url for image from network -> write url to 
     Image's file url);
* After iterating over all Holders(on this step all images inside Holders
 should have filled url), make upload for Holders;

Я пробовал что-то вроде: 

Observable.fromIterable(holders)
  .concatMap(holder -> {
    Observable.fromIterable(holder.images)
      .concatMap(image -> {
        // decode bitmap here
        uploadImage(bitmap)
      })
  })
// what should I do here to get observable which emits holders,
// not result from uploadImage(bitmap)?
  .toList()
  .flatMap(? -> uploadeHolders());

Можно ли повторитьнад данными, выполнить какое-либо действие для каждого элемента данных и выполнить некоторую работу с подготовленными данными (с выполненным действием для каждого элемента)?

1 Ответ

0 голосов
/ 18 февраля 2019

Что-то в этом роде - 

Observable.fromIterable(holders)
  .concatMap(holder -> {
    Observable.fromIterable(holder.images)
      .flatMap(image -> {
        // decode bitmap here
        uploadImage(bitmap)
        .map(url -> {
          image.url = url;
          return image;
        });
      })
      .toList()
      .map(list -> {
        holder.images = list;
        return holder;
      });
  })
  .toList(); // optional, if you need holders as a list
...