android RxJava可见。从发送到服务

Question

我有一个项目列表，需要提取一些值并为每个项目调用api。为了做到这一点，我用了这样的东西_

Observable.from(myList)
   .flatMap{ item ->
      return serviceInteractor.uploadToServer(item)
   }
   .map { serverResponse ->
       return serverResponse.getResponseCode
   }
   .toList()
   .subscrible{ responseList ->
   // do something with all the responses
   }

好吧，问题是，我不知道为什么所有的调用都是并行的。难道它不应该等待第一个响应，映射结果，然后从可观察到的对象开始下一个项目吗。from（）并在最后返回responseMessages的最终列表？正在发生的是，一切都同时发生。为了证实这一点，如果我在toList方法之前加上一个延迟（1，TimeUnit.Seconds），那么所有事情都同时发生，只有最后的onNext被延迟。

我怎样才能做到这一点？有一个ID列表，要逐个上载到服务器，等待每个ID完成，如果成功或失败，请继续下一步

Answer 1

是的，您需要使用ConcatMap

平面贴图使用合并操作符，而concatMap使用concat操作符。

所以序列是这样的

flatMap输出序列已合并，concatMap输出序列已排序

如本答案所述

在这里你可以看看这个例子

String arrData[] = {"0", "1", "2", "3", "4"};
Integer arrDelay[] = {1000, 6000, 4000, 9000, 2000};

Observable.from(arrData)
            .concatMap(s -> Observable.from(arrData)
                      .delay(arrDelay[Integer.parseInt(s)],TimeUnit.MILLISECONDS))

            .map(integer -> integer)
            .toList()
            .doOnCompleted(() -> Log.v("log", "doOnCompleted"))
            .subscribe(integer -> Log.v("log", "" + integer));

在这里，您可以检查延迟是否为我们使用的项目的总延迟

我知道我已经迟了回答这个问题：）

Answer 2

flatMap将“堆叠”调用。它将订阅每个可观察结果，然后按照它们到达的顺序发出结果。因此，可能无法订购结果（cf文档）。

如果希望对结果进行排序，应该查看concatMap操作符。（见文件）

Observable.from(myList)
     .concatMap{ item ->
              return serviceInteractor.uploadToServer(item)
      }
     .map { serverResponse ->
         return serverResponse.getResponseCode
      }
     .toList()
     .subscrible{ responseList ->
         // do something with all the responses
     }

你可以通过这篇博文获得更多信息。