RxJava：合并2个列表，忽略列表2中缺失的项目

Question

当我的应用程序处于离线状态时，远程用户可以在本地用户编辑LocalList时添加和删除远程列表中的对象。
当应用程序再次连接时，它应该同步这两个列表。
大理石图显示列表应该如何合并




例如，以下是同步前每个列表中的对象id：
远程列表： 0,1,2（已删除），3（新），4（新）
LocalList： 0,1（删除），2,3（新）

同步时，必须更改id以防止两个具有相同id的独立对象。

MergedList： 0,3,4,5（本地id 3改为5）

我正在试验RxJava，所以快速指出正确的方向会很好。合并叉组合？也许使用过滤器并向isSynced这样的对象添加一个字段？

Answer 1

以单的形式获取每个列表

record Item(int id, boolean added, boolean deleted) { }

Single<List<Item>> remoteListSource = ...
Single<List<Item>> localListSource = ...

Single.<List<Item>>zip(remoteListSource, localListSource, 
(remoteList, localList) -> {

    Set<Integer> deleted = new HashSet<>();

    // collect deleted ids
    remoteList.stream()
        .filter(item -> item.deleted)
        .forEach(item -> deleted.add(item.id));
    localList.stream()
        .filter(item -> item.deleted)
        .forEach(item -> deleted.add(item.id));

    Set<Integer> duplicate = new HashSet<>();
    List<Item> result = new ArrayList<>();

    // go through both lists, ignoring deleted ids
    Stream.concat(remoteList.stream(), localList.stream())
    .filter(item -> !deleted.contains(item.id))
    .forEach(item -> {
         // id already seen?
         if (duplicate.contains(item.id)) {
             // if this is an addition, generate new item
             if (item.added) {
                 
                 item = new Item(Collections.max(duplicate) + 1, true, false);
                 duplicate.add(item.id);
                 result.add(item);
             } else {
                 // else we have an unmodified item already in result
                 // nothing to do
             }
         } else {
             // was not a duplicate, remember it
             duplicate.add(item.id);
             result.add(item);
         }
    });

    return result;
})
.subscribe(combinedList -> { /* ... */ });