javascript - 使用Rxjs过滤可观察

我正在尝试获取当前用户的活动作业列表：

jobListRef$: Observable<Job[]>;
...
this.afAuth.authState.take(1).subscribe(data => {
  if (data && data.uid) {
    this.jobListRef$ = this.database.list<Job>('job-list', query => {
         return query.orderByChild("state").equalTo("active");
    })
    .snapshotChanges().map(jobs => {
         return jobs.map(job => {
              const $key = job.payload.key;
              const data = { $key, ...job.payload.val() };
              return data as Job;
         });
    })
    .filter(val =>
         val.map(job => {
              return (job.employer == data.uid || job.employee == data.uid);
         })
    );
  }
});

问题仅从过滤开始。根据官方文档，其参数的正确部分应返回布尔值，就像我的情况一样。但是它仍然返回我整个条目而不过滤它们。

最佳答案

我相信您想逆转地图和过滤器运算符。

.map((jobs: Job[]) =>
  jobs.filter((job: Job) => job.employer === data.uid || job.employee === data.uid )
);

（map将一个数组转换为另一个数组，filter缩小数组）。

或者，您可以将过滤器链接到执行类型转换的地图上，

.map(jobs => {
  return jobs.map(job => {
    const $key = job.payload.key;
    const data = { $key, ...job.payload.val() };
    return data as Job;
  })
  .filter(job => job.employer === data.uid || job.employee === data.uid )
})

关于javascript - 使用Rxjs过滤可观察，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/47122974/