У меня есть массив, который я хотел бы фильтровать. Звучит просто, я знаю. Но когда я это делаю, я все равно получаю весь массив...
constructor(http:Http) {
this._val = Math.random();
let s = http.get('https://secure.digitalsignage.com/Digg');
s.map(s => {
let news = JSON.parse(s._body);
return Rx.Observable.fromArray(news);
}).filter(function(data) {
console.log('all array ' + data);
return true;
}).subscribe(function (v) {
console.log(v);
});
}
поэтому в console.log('all array' + data); Я получаю весь массив вместо потока отдельных элементов массива, почему?
здесь отладка:
Я знаю, что я не сумасшедший, потому что это работает так, как ожидалось:
Rx.Observable.fromArray([1, 2, 3, 4, 5]).filter(function (v) {
if (v < 3)
return true
return false;
}).subscribe(function (v) {
console.log(v);
})
что дает?
tx для чтения,
Шон.