如何使用 observable 制作过滤器

Question

我正在尝试对我的 observable 进行过滤

private ListpplSource = new BehaviorSubject<ppl[]>([]);

  Listppl$ = this.ListpplSource.asObservable();

  ShowAllPpl(){
    this.service.bringAllppl().subscribe(data =>{
      this.ListpplSource!.pipe (
        map(items => 
         items.filter(item => item.codempresa == 1 ))).next(data)
    
         
    })
  }

但我在.next(data) 上显示红色下划线：

“Observable”类型上不存在属性“next”。

所以基本上我希望我的 Listppl$ 只获取 item.codempresa == 1 的项目，因为我的服务给我带来了所有的对象，而我只是一个有 item.codempresa == 1 的对象。我需要使用下一个（数据）使其始终可见

Answer 1

我想你想要这样的东西：

this.service.bringAllppl().subscribe(data => {
  const filteredData = data.filter(item => item.codempresa === 1);
  this.ListppSource.next(filteredData);
});