RxJava - 在发射项目的排序列表中添加标题

Question

假设我有一个项目列表并发出它：

Observable<Item> items = Observable.fromIterable(list);

现在我想要第二个插入标题的 observable。是否必须插入标题可以通过比较两个连续的项目来决定。任何想法如何做到这一点？

逻辑如下：

• 比较两个连续的项目
• 如果他们需要不同的标题，请在它们之间添加一个新的标题项
• 如果没有，就发出项目

我需要类似于 scan 的东西，但操作员必须发出输入项 + 可选标题项...

Answer 1

您可以使用滑动窗口进行缓冲，并在重叠窗口上执行 flatMap 以在项目之间插入标题/分隔符：

Observable.just(1, 3, 4, 5, 7, 8, 10, 12, 14)
.buffer(2, 1)
.flatMapIterable(v -> {
    if (v.size() <= 1) {
        return v;
    }
    if (v.get(1) - v.get(0) > 1) {
        return Arrays.asList(v.get(0), 1000);
    }
    return Collections.singletonList(v.get(0));
})
.subscribe(System.out::println);