javascript - 如何使用 RxJS 运算符过滤数组

Question

大家好，我是 RxJs 和响应式编程的新手，我想像这样过滤一个数组:

let subscription = Rx.Observable.from([{id: 1}, {id: 2}, {id: 3}],[{id: 4}, {id: 5}, {id: 6}]);

如果我有一个数组 a 我可以这样做:

let subscription = Rx.Observable.from([{id: 1}, {id: 2}, {id: 3}]);


subscription.filter(x => x.id === 1).subscribe(x => console.log(x));

但是我该如何处理第二个数组呢？

Answer 1

如果您知道您将始终拥有数组数组，您可以展平数组然后运行 ​​filter:

const o = Rx.Observable.of([{id: 1}, {id: 2}, {id: 3}],[{id: 1}, {id: 2}, {id: 3}])
  .concatMap(array => array) // flatten the array into single emissions
  .filter(x => x.id === 1)
  .subscribe(x => console.log(x));

我正在使用接受多个参数的.of。然而，它采用它们，因为它们不同于迭代数组的 from 方法。