我正在尝试设置一个可观察的流,我将最近的设置值与最后一个设置值进行比较,我想根据两者之间的一些变化进行过滤.我在服务中设置了一个BehaviorSubject(Angular 2,如果这很重要)并创建了函数来返回它：
getFilters() {
return this.filteRSSubject.asObservable();
}
然后在使用它的组件中,我正在尝试这个：
this.eventFilterService.getFilters()
.takeLast(2)
.subscribe((data) => console.log(data));
但我没有控制台日志.如果我删除了takeLast,我会看到我的数据返回.从文档中,我的假设将是原样,它只会发射两次.我的目标是将takeLast输入reduce然后过滤器.
我使用takeLast错了吗？
