如何使用observable的输出来过滤另一个

Question

所以我有两个observable，一个返回当前类别和其他产品。我希望根据类别过滤产品。

这是角2，所以我真的希望我的NG2视图是用户（通过异步管道）。

像这样简单的例子：

let category$ = Observable.of({id: 1}); 
let products$ = Observable.from([{name: 'will be included', cat_ids: [1, 5]}, {name: 'nope', cat_ids: [2, 3]}, {name: 'also yep', cat_ids: [1, 7]}]); 

return products$ 
    .toArray() 
    .filter(prod => { 
    return prod.cat_id.some(id => id === <how do I get the value of the category observable here?>) 
    }); 

也许答案很简单，但它躲开我。

Answer 1

您需要加入这两个流，例如与combineLatest：

let category$ = Observable.of({id: 1}); 
let products$ = Observable.from([{name: 'will be included', cat_ids: [1, 5]}, {name: 'nope', cat_ids: [2, 3]}, {name: 'also yep', cat_ids: [1, 7]}]); 

return Observable.combineLatest(products$, category$) 
    .map(([products, category]) => { 
    return products.filter(prod => prod.cat_id.some(id => id === category.id); 
    }); 

更新

由于@olsn指出了Observable.from你得到的事件流不流事件的数组。因此，解决方案应该是：

let category$ = Observable.of({id: 1}); 
let products$ = Observable.from([{name: 'will be included', cat_ids: [1, 5]}, {name: 'nope', cat_ids: [2, 3]}, {name: 'also yep', cat_ids: [1, 7]}]); 

return Observable.combineLatest(products$, category$) 
    .filter(([product, category]) => { 
    return product.cat_id.some(id => id === category.id); 
    }) 
    .map(([product, category]) => product);