Rxjs结合2个观测，角2

Question

我有2个观测，这两个HTTP调用：

itemList$:Observable<any[]>; 
newItem$:Observable<any[]>; 

ngOnInit(){ 
    itemList$ = this.http.getList(...some url...) // returns array of many items 
} 

createNewItem(){ 
    newItem$ = this.http.createNewItem(...some url...) //returns array of one item 
} 

我想称之为“createNewItem（）”函数从其他地方，我想结果被合并用当前的itemList $ observable结果来形成一个项目数组。

在HTML我有一个异步管这就是听itemList中$：

<div *ngFor="let item of itemList$ | async">{{item.name}}</div> 

我怎么能合并的newitem $到itemList中$，并有异步管显示合并的结果吗？

Answer 1

您可以使用Observable.merge（我有RxJS版本5.0.1）

Observable.merge(newItem$, itemList$) 
      .subscribe(response => { 
       // Perform your action 
      }); 

https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/merge.md

Answer 2

您可以使用Subject而不是Observable s。只要你创建一个新的项目，交给主题并发布它。

itemList$:AsyncSubjct<any>; 

createNewItem(){ 
    this.http.createNewItem(...some url...).subscribe(data => { 
    this.itemList$.next(data); 
}