import { Observable } from 'rxjs/Observable';
import "rxjs/add/operator/take";
import "rxjs/add/observable/interval";
let sourceArray = [1,2,3,4,5,6,7,8,9];
let destArray = [];
let stream = Observable.interval(1000)
.take(sourceArray.length)
.map(waarde => { return sourceArray[waarde]; });
.take(sourceArray.length)
.map(waarde => { return sourceArray[waarde]; });
stream.subscribe(waarde => {
destArray.push(waarde);
});
Geen opmerkingen:
Een reactie posten