Get kątową obserwowalnych strumień jako tablicy

Question

Mam listy, które powinny symulować strumienia:

list = [ 
    {name : 'Str1', age: 10}, 
    {name : 'Str2', age: 10}, 
    {name : 'Str3', age: 10} 
]; 

a ja stworzył Observable z tej listy:

Observable.from(this.list).skip(this.currentPage * this.pageSize).take(this.pageSize).subscribe(data => this.pagerList = data, console.error); 

aw subskrybować Metoda otrzymuję wartości jeden po drugim. Jak mam poczekać na zwrócenie wszystkich danych, a potem na całą listę. Jest operator take(), a po nim obserwowalne muszą się zatrzymać.

Nie chcę umieszczać każdej wartości pojedynczo w tablicy.

Jestem nowy tutaj, nie tylko dla kanciastych, ale także dla javascriptu.

Answer 1

Czy próbowałeś użyć toArray operatora ?.

let list = [ 
 
    { name: 'Str1', age: 10 }, 
 
    { name: 'Str2', age: 10 }, 
 
    { name: 'Str3', age: 10 }, 
 
    { name: 'Str4', age: 10 }, 
 
    { name: 'Str5', age: 10 }, 
 
    { name: 'Str6', age: 10 } 
 
]; 
 

 
let currentPage = 2; 
 
let pageSize = 2; 
 

 
Rx.Observable.from(list) 
 
    .skip(currentPage * pageSize) 
 
    .take(pageSize) 
 
    .toArray() 
 
    .subscribe(data => console.log(data), console.error);

<script src="https://npmcdn.com/@reactivex/rxjs@5.0.3/dist/global/Rx.min.js"></script>

Answer 2

Operator scan powinien robić to, co chcesz

Observable.from(this.list) 
.skip(this.currentPage * this.pageSize) 
.take(this.pageSize) 
.scan([], acc, curr) => {acc.push(curr); return acc;}); 
.subscribe(data => this.pagerList = data, console.error); 

http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-method-scan

Answer 3

myślę, że to jest bardziej odpowiednie rozwiązanie:

Observable.of(this.list).map(x => x.slice(this.currentPage * this.pageSize)).map(x => x.slice(0, this.pageSize)).subscribe(data => this.pagerList = data, console.error);