ReplaySubject 已“完成”时发出信号

Question

我正在尝试找出一个好方法来表明 ReplaySubject 当前为“空”。

import {ReplaySubject} from 'rxjs/ReplaySubject';
const rs = new ReplaySubject<Object>();

 // ...
constructor(){
  this.sub =  rs.subscribe(...);
}

每次调用构造函数时，它都会重播主题中的所有项目。但是我的问题是 - 是否有一些我们可以听的事件，它告诉我们什么时候主题变空？

我唯一能想到的就是在主题完成后触发一个自定义/不同的事件，如下所示：

rs.next({done:true});

将数据传递给 next() 方法是表明 ReplaySubject （暂时）为空/没有事件的最佳方式吗？

Answer 1

因为 Subject 也是一个观察者，所以你可以在最后一次调用 next() 之后调用 complete()。然后你可以用subscribe(...)方法的第三个参数来监听它。

const rs = new ReplaySubject<Object>();
rs.next({a: 1})
rs.complete()

rs.subscribe(
    obj => console.log(obj),
    error => {},
    () => console.log('completed')
);
// Outputs
// {a: 1} completed

Answer 2

现在，我想你可以设置一个辅助 observable 来告诉你最后重播的项目是什么：

const last$ = rs.replay(1);

然后你只需 combineLatest 并扫描...一旦你到达 last$ 发出的项目，那么你的 ReplaySubject 就完成了重播：

this.sub = Observable.combineLatest(
  rs,
  last$.take(1)
).scan((acc: { item: Object, isReplay: boolean }, curr: [Object, Object]) => {
    return {item: curr[0], isReplay: acc.isReplay && curr[0] !== curr[1]};
  }, {isReplay: true}
).subscribe(...);