我不能再将forkjoin与rxjs 5.5一起使用。2.

Question

最近，我决定将一个使用Angular的“快速启动”从头开始创建的大项目迁移到使用Angular CLI 1.5.5的版本。现在，我正在解决出现的不同问题，我无法解决这个问题。

我读到使用rxjs的可出租操作符更好，我做到了，而且效果很好。但是，我也有以下代码行：

import { Observable } from "rxjs/Observable";
import "rxjs/add/observable/forkjoin";

...

let piecesGrouping$: Observable<IGroupedPiece[]>[] = deliveries.map(delivery => this._pieceService.getGroupedPieces(delivery.pieces));

Observable
  .forkJoin(...piecesGrouping$)
  .subscribe((groups) => {
    groups.forEach((group, i) => deliveries[i].groupedPieces = group);

    resolve();
  });

在使用rxjs 5.4的前一个版本中，它们工作得非常好。3，现在使用rxjs 5.5。2，它们不再存在，我得到以下错误：

错误错误：未捕获（在promise中）：TypeError：无法读取未定义TypeError的属性应用：无法读取未定义的属性应用

我试图替换的扩散运算符由片段分组$[0]，片段分组$[1]作为错误没有说任何关于forkJoin本身，然后我得到：

错误错误：未捕获（promise中）：类型错误：WEBPACK\u IMPORTED\u MODULE\u 8\u rxjs\u Observable。a、 forkJoin不是一个函数类型错误：WEBPACK\u IMPORTED\u MODULE\u 8\u rxjs\u Observable。a、 forkJoin不是一个函数

看来我导入forkJoin的方式不对。我试图从“rxjs/observable/forkJoin”中导入它，但也没有成功。

我错过了什么？

Answer 1

你应该把它当作一个函数

forkJoin(...piecesGrouping$)
  .subscribe((groups) => {
    groups.forEach((group, i) => deliveries[i].groupedPieces = group);

    resolve();
  });

导入语句更改为

import { forkJoin } from "rxjs/observable/forkJoin";

这是作为5.2版本的一部分发布的。阅读更改日志

Answer 2

RxJS 6. x使用此导入

从rxjs导入{forkJoin}；

如其他答案所述，它仍然需要作为一个函数使用，因为它现在是独立的。医生来了

Answer 3

不要使用可观察的修补，直接使用forkJoin：

import {forkJoin} from "rxjs/observable/forkJoin";

forkJoin(...piecesGrouping$).subscribe()

查看此资源以详细了解forkJoin。