Tag: angular2 observables

用angular2 observablesasynchronous填充Object属性？: 我想转换一个angular2组件来使用asynchronous数据调用。我使用专用图表库将数据显示在图表上。图表需要以某种格式传递数据（如下所示）。 public barChartData: any[] = [ { data: this.dataService.getCellOEE('powders'), label: 'OEE' } ]; 问题是this.dataService.getCellOEE('powders')返回一个可观察的。如果我像[datasets]="(barChartData | async)"一样绑定到图表对象， [datasets]="(barChartData | async)"抛出一个错误，因为显然barChartData是一个对象而不是可观察对象。我如何asynchronous使用已parsing的Observable数据填充静态对象的一部分，然后将该静态对象绑定到我的Chart UI组件的datasets属性？

无法从连接的Observable提取/解包值: 我有这个链应该将10个Observable链接成1个Observable，其中10个Observable中的每一个基本上都应该被解开为一个整数： const Rx = require('rxjs'); var i = 0; const obs = Rx.Observable.interval(10) .map(() => i++) .map(val => Rx.Observable.create(obs => { obs.next(val) })) .take(10) .reduce((prev, curr) => { return prev.concat(curr); // concat all observables }) .last(val => val.flatMap(inner => inner)); // subscribe to Observable obs.subscribe(v => { console.log('\n next (and only) result => \n', v); […]

Promise.resolve（）但是Observables（RxJS5）: 好了，为了更好地学习RxJS，我决定尝试创build一个自定义的Rx操作符。所以这是一个简单的工作正常： Rx.Observable.prototype.multiply = function (input) { const source = this; return Rx.Observable.create(function (obs) { return source.subscribe(function(val){ obs.next(input*val); }); }); }; 我们可以像这样使用它： const obs = Rx.Observable.interval(1000) .multiply(4) .forEach(function (v) { console.log(v); }); 然而，如果我们得到一些更复杂的东西，例如，如果我们的操作符采用一个函数而不是一个静态值。 Rx.Observable.prototype.handleFn = function (fn) { const source = this; return Rx.Observable.create(function (obs) { return source.subscribe(function(val){ obs.next(fn.call(obs,val)); }); }); }; 上面的内容都很好，但是如果我们需要处理从input函数返回的Rx.Observable，如下所示： const […]