【发布时间】:2016-12-15 04:52:55
【问题描述】:
我正在尝试从数组中创建一个 observable,正如 https://github.com/ReactiveX/rxjs/blob/master/doc/observable.md 中的文档所述:
import {Observable} from 'rxjs/Observable';
let theList = Observable.from(sites);
但我明白了:
TypeError: Observable_1.Observable.from is not a function
我的目标是在 Observable 序列上使用像 reduce 或 scan 这样的运算符,因为标准的 Observable 似乎不支持,如下所示:
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;
});
代码可以在这个 Plnkr 中找到:http://plnkr.co/edit/cKEqtp (src/app.ts)。
谢谢!
【问题讨论】:
标签: angularjs typescript rxjs