Angular/TypeScript：在订阅中编写代码

Question

我正在使用 Angular (4)，需要帮助来处理异步数据：

您可以在下面看到方法connect()。第一个命令订阅了我的服务的 Observable。以下行也需要在此订阅中。但我不知道怎么做。该方法应将 getSortedData() 方法的结果作为 Observable 返回。

我的项目组件

   //...
    items: Item[];
    //...
    connect(): Observable<Item[]> {
            this.myItemService.getItem().subscribe(response => {
                this.items = response;
            });
            const displayDataChanges = [
                this.myItemService.getItem(),
                this.sort.sortChange,
            ];
            return Observable.merge(...displayDataChanges).map(() => {
                return this.getSortedData(this.items);
            });
        }
    //..

Answer 1

不要读取操作符内部的可变状态。当它们发生变化时，observable 将不知道也不会再次运行您的代码。

所以我删除了this.items 的使用，并将sort 参数传递给getSortedData()。

connect(): Observable<Item[]> {
  const displayDataChanges = [
    this.myItemService.getItem(),
    this.sort.sortChange,
  ];
  return Observable.combineLatest(...displayDataChanges).map(([items, sort]) => {
    return this.getSortedData(items, sort);
  });
}

我调用 combineLatest() 而不是 merge()，它将在每次任何可观察值发生变化时运行以下运算符，并使用每个运算符的最新值。