I'm trying to create an observable from an array, as documentation says in https://github.com/ReactiveX/rxjs/blob/master/doc/observable.md:
import {Observable} from 'rxjs/Observable';
let theList = Observable.from(sites);
but I get:
TypeError: Observable_1.Observable.from is not a function
my goal is to use operators like reduce or scan over a Observable sequence, as a standard Observable seems to not support, as below:
this.theList = new Observable(observer => {
// this works
observer.next(sites);
});
this.sub = this.theList.reduce(function() {
// this is never called
return acc;
}).subscribe(l => {
// this is never called
this.finalList = l;
});
The code can be found in this Plnkr: http://plnkr.co/edit/cKEqtp (src/app.ts).
Thanks!