Observable.flatMap是为此目的而制作的(小提琴):
// turn products into array
var arr = [];
for(var key in products) {
arr.push(products[key]);
}
Rx.Observable.from(arr)
.flatMap(x => {
// 'x' is like object ID1, create array of products
var arr = [];
for (var key in x) {
arr.push(x[key]);
}
return Rx.Observable.from(arr);
})
.subscribe(x => document.write(JSON.stringify(x) + '</br>'));
输出:
{"name":"Car"}
{"name":"Door"}
{"name":"Glass"}
{"name":"Sandwich"}
{"name":"Pen"}
不确定您想如何处理键,但您可以使用Observable.pairs它来更轻松地遍历对象属性。结果流是数组,第一个元素是键,第二个元素是对象属性的值:
Rx.Observable.pairs(products)
.flatMap(x => Rx.Observable.pairs(x[1]))
.subscribe( x => console.log(x[0], x[1]));
这将返回如下数组:
["prodID1", {name: "Car"}]
["prodID2", {name: "Door"}]
["prodID3", {name: "Glass"}]
["prodID4", {name: "Sandwich"}]
["prodID5", {name: "Pen"}]