takeLast似乎杀死了可观察的流

Question

我正在尝试设置一个可观察的流,我将最近的设置值与最后一个设置值进行比较,我想根据两者之间的一些变化进行过滤.我在服务中设置了一个BehaviorSubject(Angular 2,如果这很重要)并创建了函数来返回它:

getFilters() {
    return this.filtersSubject.asObservable();
}

然后在使用它的组件中,我正在尝试这个:

this.eventFilterService.getFilters()
    .takeLast(2)
    .subscribe((data) => console.log(data));

但我没有控制台日志.如果我删除了takeLast,我看到我的数据返回.从文档中,我的假设将是原样,它只会发射两次.我的目标是将其takeLast转换为减少然后过滤器.

我使用takeLast错了吗？

Answer 1

takeLast(x)将等待完成Observable,然后才能发出最后一次x排放.由于您使用了一个主题,因此需要调用complete()它来使其工作.

但你真的想计算两次发射之间的差异.为此,请使用.buffer()操作员

Rx.Observable.from([2,3,5,8])
     .bufferCount(2,1)
     .map(buff =>  buff[1] - buff[0])
     .subscribe(delta => console.log(delta))