RxJS 等待嵌套的 observable 过滤数组数据

Question

有两个Observables：foo 和bar。

foo 将返回 array 对象，例如 [{ id: 1 }, { id: 2 }, ...]（它将返回整个数组（在此处使用 AngularFire .list））

bar 对从foo 返回的每个项目都有一个存储值。该值存储为一个对象，如下所示：{ id: 2, status: false }。

这里需要做的是最初调用foo，在它的map函数中，我想从subscribe()方法中取出{ id: 2 }，如果它在bar的响应中匹配值是false。

换种说法

1. 观看来自foo 的流
2. .map 对象并检查来自bar 的每个对象 状态
3. bar 返回一个值为 true 或 false 的 observable
4. .filterfoo取出任何带有status的对象为false

我尝试了combineLatest、zip 和其他RxJS 方法，但不确定我是否正确执行此操作。有人可以告诉我正确的方法，或者至少指出我们应该探索哪些方法吗？

感谢您的帮助！

谢谢。

//

.... foo
....... itemId1
....... itemId2

.... bar
....... itemId1: true
....... itemId2: false

订阅foo时，它返回的数组必须是filtered才能返回itemId1，因为它的bar值是true（都是observables，foo和bar ofc）

Answer 1

这是完成工作的一段代码：

foo = Rx.Observable.of([
  {id: 1, data: 'foo1'}, 
  {id: 2, data: 'foo2'}, 
  {id: 3, data: 'foo3'}, 
  {id: 4, data: 'foo4'}, 
  {id: 5, data: 'foo5'}, 
  {id: 6, data: 'foo6'}
]);

bar = Rx.Observable.of([
  {id: 1, status: false}, 
  {id: 2, status: true}, 
  {id: 3, status: true}, 
  {id: 4, status: false}, 
  {id: 5, status: true}, 
  {id: 6, status: false}
]).flatMap(obj => obj);

Rx.Observable.combineLatest(foo, bar)
    .filter(([foo, bar]) => bar.status)
    .map(([foo, bar]) => foo.find(obj => obj.id === bar.id))
  .subscribe(data => {
    console.log(data)
  });