angular – takeLast似乎杀死了可观察的流

发布时间：2020-12-17 17:22:50 所属栏目：安全来源：网络整理

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

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

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

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

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

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

我使用takeLast错了吗？

解决方法

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))

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!