组合观察对象并行运行

Question

如何组合两者以便它们并行或串行运行？

Observable<Data>) dataRequestOne; 
Observable<Data>) dataRequestTwo; 

Answer 1

尝试拉链操作：http://reactivex.io/documentation/operators/zip.html

Observable.zip(dataRequestOne, dataRequestTwo, new Func2<Data, Data, Object>() { 
     @Override 
     public Object call(Data o, Data o2) { 
      return null; 
     } 
    }); 

Answer 2

如果你想比你需要使用合并操作

http://reactivex.io/documentation/operators/merge.html

Observable.mergeDelayError(
       dataRequestOne.subscribeOn(Schedulers.newThread()), 
       dataRequestTwo.subscribeOn(Schedulers.newThread()) 
     ) 

Answer 3

使用串行响应在onNext为每个请求平行：

Observable.merge(dataRequestOne, dataRequestTwo) 

编号：

Observable.concat(dataRequestOne, dataRequestTwo); 

Answer 4

要做到这一点是可以做到这一点：

Observable.just(dataRequestOne, dataRequestTwo).flatMap(new Func1<Data, Observable<Data>>() { 
     @Override 
     public Observable<Data> call(Data data) { 
      return Observable.just(data) 
          .subscribeOn(Schedulers.io); 
     } 
    }); 

现在每个请求将在一个单独的线程处理。 FlatMap还有一个可选的maxConcurrent参数，所以如果你有更多的观察值，你可以控制处理请求的线程数量（如果有必要的话）。