reactive-programming - 如何使用 StartWith() rx 运算符但仅当序列不为空时？

Question

我有一个 rx observable，我需要添加一个特定的项目，但前提是 observable 至少发出一个项目。

我找遍了所有的运营商，但找不到合适的。最接近的是 StartWith但根据图表，它会立即发出项目，并且不会计算下一个项目。

是否可以通过将其与其他一些运算符结合来实现这一点？
谢谢。

Answer 1

我一直在尝试做同样的事情，我想出的唯一一件事不是很被动:

    Observable.just(1, 2, 3)
    .toList()
    .flatMap(items -> {
      if (items.size() > 0) {
        items.add(0, 0);
      }
      return Observable.from(items);
    })

它远非完美，在“热”可观察的情况下将不起作用。