rxjava连续concatmap如何按阶段开始发射

Question

Observable.from(Iterable)
      .concatMap(new Function<T,R>(){
      public interface ObservableSource<T> {
           1. ...........          
      })
      .concatMap(new Function<T,R>(){
      public interface ObservableSource<T> {
           2. ...........          
      })
      .concatMap(new Function<T,R>(){
      public interface ObservableSource<T> {
           3. ...........          
      })
      .subScribe(new Consumer()........
      
      

现在是有的网络请求快的话已经走到3了慢的还在走1，如何让源按全部走完1，再开始按序走2、3。

Answer 1

你是要第一个阶段全都完成,才开始2,3阶段?那么你可以收集好第一阶段的全部值然后再开始2,3阶段
可以考虑用toList,buff,zip这些操作符