Rxjava2.x 使用强大的操作符来处理嵌套请求

最近遇到一个需求，大概内容如下：

1、请求A接口返回对象集合(假设对象是VideoTest 有一个参数url跟参数名id)；
2、需要再根据每个对象的id 请求接口B ，接口B会返回最终的url字符串；
3、再把接口B返回的url设置到对应的对象上，然后最终返回所有有了正确的url参数的对象集合。

一开始听到这个需求，我感觉很简单 先请求接口A得到集合之后 在for循环一个一个请求 在设置到对应的对象上，但是这样对于使用rxjava的人来说 真的是丑到爆！！！然后我就网上找啊找，找了半天没找到 那就自己动手 然后我就去百度rx2.x的操作符大全 一个一个看 有没有能适用于这个需求的，功夫不负有心人啊 。下面直接上代码吧

public class Test {
private Map<Integer, VideoTest> map = new HashMap<>();
private int index = 0;

public void test() {
    List<VideoTest> videoTests = new ArrayList<>();

    for (int i = 0; i < 6; i++) {
        VideoTest videoTest = new VideoTest("qwert" + i, "http:www.dddd.com/" + i);
        videoTests.add(videoTest);
    }
    Observable.fromArray(videoTests)//这里模拟请求数据集合
            .flatMap(new Function<List<VideoTest>, ObservableSource<VideoTest>>() {
                @Override
                public ObservableSource<VideoTest> apply(@NonNull List<VideoTest> pVideoTests) throws Exception {
                    index = 0;
                    return Observable.fromIterable(pVideoTests);// 这里的fromIterable是一个一个发送数据
                }
            })
            //单独处理每个数据
            .map(new Function<VideoTest, String>() {
                @Override
                public String apply(@NonNull VideoTest pVideoTest) throws Exception {
                    //这里需要使用map来绑定对象跟key key可以使用integer
                    map.put(index, pVideoTest);
                    return pVideoTest.getUrl();
                }
            })
            .map(new Function<String, String>() {
                @Override
                public String apply(@NonNull String ps) throws Exception {
                    //这边处理url 应该是请求接口B 我这就简单点处理了
                    return ps + "处理过的";
                }
            })
            .map(new Function<String, VideoTest>() {
                @Override
                public VideoTest apply(@NonNull String pS) throws Exception {
                    //这边应该将正确的url赋值给对应的对象
                    VideoTest videoTest = map.get(index);
                    videoTest.setUrl(pS);
                    index++;
                    return videoTest;
                }
            })
            //这个操作符是用来收集对象的
            .collect(new Callable<List<VideoTest>>() {
                @Override
                public List<VideoTest> call() throws Exception {
                    return new ArrayList<>();
                }
            }, new BiConsumer<List<VideoTest>, VideoTest>() {
                @Override
                public void accept(List<VideoTest> pNewses, VideoTest pNews) throws Exception {
                    pNewses.add(pNews);
                }
            }).subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Consumer<List<VideoTest>>() {
                @Override
                public void accept(List<VideoTest> pVideoTests) throws Exception {
                    for (VideoTest v : pVideoTests) {
                        Logger.e("----s---d--d-d--d-d-d-d-" + v.getId() + "," + v.getUrl());
                    }
                }
            }, new Consumer<Throwable>() {
                @Override
                public void accept(Throwable pThrowable) throws Exception {
                    Logger.e(pThrowable.getMessage());
                }
            });

}

我觉得map的key你们可以请你们后台加一个特殊字段来识别 两个接口返回的时候都该有相同的字段 这样就好处理了。