带有条件存储的 rxjs publishReplay

Question

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

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

Answer 1

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