具有反应性副作用的反应性流

Question

我认为这将与大多数反应式实现类似地完成，所以我没有在这里指定任何特定的库和语言。

对流进行反应性副作用的正确方法是什么（不确定这里的正确术语是什么）？

假设我们有一个Players 流。我们希望将其转换为只有ids 的流。但除此之外，我们还想根据 id 做一些额外的反应式处理。

这是一个不太优雅的方式，但实现这一点的惯用方式是什么：

Observable<Player> playerStream = getPlayerStream();
return playerStream
      .map(p -> p.id)
      .flatmap(id -> {
           Observable<Result> weDontCare = process(id);
           // Now the hacky part
           return weDontCare.map(__ -> id);
      })

这样好吗？似乎没有那么优雅。

Answer 1

我不知道 RxJava，但是您也标记了项目反应器，并且有两种方法可以使用反应器来执行此操作，具体取决于您希望副作用如何影响您的流。如果您想等待副作用发生以便处理错误等（我的首选方式），请使用 delayUntil：

return getPlayerStream()
  .map(p -> p.id)
  .delayUntil(id -> process(id));

如果您希望 id 直接通过而无需等待，而是执行“即发即弃”风格的副作用，您可以使用 doOnNext：

return getPlayerStream()
  .map(p -> p.id)
  .doOnNext(id -> process(id).subscribe());

Answer 2

Observable<Player> playerStream = getPlayerStream();
    return playerStream
          .map(p -> p.id)
          .doOnEach(id -> { //side effect with id
            Observable<Result> weDontCare = process(id);
            weDontCare.map(__ -> id);
          })