在这里,我用过forkJoin
从 rxjs 并行订阅可观察数组。但我想一一订阅,最好的解决方案是什么?
下面是我的代码:
var observables = [];
Observable.forkJoin(observables)
.subscribe(() => {
this.msgs = [];
this.msgs.push({
severity: 'success',
summary: 'Saved Successfully'
});
this.onSaveComplete();
}, (error: any) => this.errorMessage = <any>error);
}, (error: any) => this.errorMessage = <any>error);
forkJoin 的替代方法意味着您需要按顺序订阅可观察数组。merge
and concat
在这种情况下要走的路。在您的情况下,修改您的代码并在使用时在可观察数组的开头使用扩展运算符merge
and concat
.
var observables = [];
Observable.concat(...observables)
.subscribe(() => {
this.msgs = [];
this.msgs.push({
severity: 'success',
summary: 'Saved Successfully'
});
this.onSaveComplete();
}, (error: any) => this.errorMessage = <any>error);
}, (error: any) => this.errorMessage = <any>error);
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)