在RxJS auditTime Observable中强制触发事件

Question

我正在使用RxJS auditTime Observable每隔10秒将更改保存在文档中（如果有）。 它工作的很好，但有时我需要立即强制该事件，例如，当用户即将关闭文档。

E.g一些方式来“刷新”可观察到的..

什么是这样的情景最优雅的做法？

Answer 1

如果你有一个主题，即源到auditTime运营商则可以将其合并到自己是这样的：

subject.auditTime(10 * 1000) 
    .merge(subject.filter(val => val === 'close'));