javascript - 带有条件存储的 rxjs publishReplay

Question

我有一个发出消息的热可观察对象。目前我正在使用publishReplay(1).refCount()，所以每个订阅的人都会收到最后一条消息。现在，通过 May 的消息有一个包含布尔值的字段，以确定它是否应该只传递给所有订阅者，或者是否应该存储在重播中以便也发送给所有新的订阅者。

有谁知道如何实现这个用例？

Answer 1

我实现了自己的publishReplayConditionally和ConditionalReplaySubject. 它们还接受一个表达式作为参数来决定是否应该存储该值。