RxJSのイベントを強制的に実行するauditTime Observable

Question

私はRxJSのauditTime Observableを使用して、ドキュメントに変更があればそれを10秒ごとに保存します。 素晴らしいですが、ユーザーがドキュメントを閉じるなど、すぐにイベントを強制的に実行する必要があることがあります。

例えば「フラッシュ」にはいくつかの方法で観察できる。..

このようなシナリオのための最もエレガントなアプローチは何ですか？

Answer 1

あなたはauditTimeオペレータへの源である、単一の件名を持っているなら、あなたはこのように自分自身にそれをマージすることができます：私は完全に理解していない

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