javascript - RxJS:如何发出 takeWhile 评估为 false 的事件？

Question

这个问题已经有答案了:

RxJS takeWhile but include the last value (6 个回答)

已关闭 4 年前。

我有以下代码:

const kickstart$ = curry((pred, iStream, hStream) =>
    iStream()
    .pipe(
        take(1),
        flatMap(({processId: pid}) => poller$(hStream(pid))),
        takeWhile(pred),
        catchError(x => of(x))
    )
)

takeWhile一旦 pred 语句就停止流函数返回假。问题是，我也希望发出这些最终值，以便订阅者可以知道流的最终状态是什么，其中包含类似 status: stopped 的信息。或status: error ，但我希望它在那之后结束。

如果我只检查status !== "stopped" || status !== "error"在我的takeWhile ，那么最终事件将不会被发出。

我如何也包含最后一个事件？

Answer 1

您使用哪个rxjs版本？

已经有一个带有 bool 标志的 takeWhile 重载，用于包含最后。

takeWhile(pred, true)

如果您使用的是旧版本，则必须执行其他操作，例如在 takeWhile 之后连接最后发出的值

我相信包容性最后是在 6.4.0 中添加的。