woensdag 13 december 2017

Angular Observable emit value every second

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]; });

stream.subscribe(waarde => {
   destArray.push(waarde);
});