如何使用RxJava将Pair列表拆分为首元素与次元素列表？

当然可以！RxJava的操作符组合完全能帮你优雅实现这个需求，不用写手动循环～下面给你两种实用方案：

方案一：简单直接的map拆分 #

先把源Observable转换成Pair列表，再在map操作符里完成拆分逻辑——虽然内部还是有循环，但逻辑完全包裹在Rx流中，代码更整洁：

Observable<Pair<String, String>> source = ...;

Observable<Pair<List<String>, List<String>>> splitResult = source
    .toList()
    .map(pairs -> {
        List<String> allFirsts = new ArrayList<>();
        List<String> allSeconds = new ArrayList<>();
        for (Pair<String, String> pair : pairs) {
            allFirsts.add(pair.first);
            allSeconds.add(pair.second);
        }
        return Pair.create(allFirsts, allSeconds);
    });

方案二：纯Rx操作符实现（无显式循环） #

如果想要完全摆脱手动循环，推荐用publish共享源Observable，分别收集每个Pair的首尾元素，最后用zip合并结果：

Observable<Pair<String, String>> source = ...;

// 先把源转成可连接Observable，避免多次订阅导致重复遍历源数据
ConnectableObservable<Pair<String, String>> sharedSource = source.publish();

// 收集所有Pair的首元素到列表
Observable<List<String>> firstList$ = sharedSource
    .map(Pair::first)
    .toList();

// 收集所有Pair的次元素到列表
Observable<List<String>> secondList$ = sharedSource
    .map(Pair::second)
    .toList();

// 合并两个列表Observable，得到包含双列表的结果
Observable<Pair<List<String>, List<String>>> bothLists$ = Observable.zip(
    firstList$,
    secondList$,
    Pair::create
);

// 启动源数据发射
sharedSource.connect();

这种方法的好处是只遍历一次源数据，效率更高，而且全程用Rx操作符串联逻辑，完全符合响应式编程的风格。如果你的需求是要两个独立的Observable（分别发射首元素列表和次元素列表），直接用firstList$和secondList$就行，不需要最后的zip步骤。

内容的提问来源于stack exchange，提问作者amitsaurav