Observable.fork连接和数组参数

Question

在Observables forkJoin文档中，它说args可以是数组，但没有列出这样做的示例：

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

我已经尝试了类似于我列出的功能（如下），但出现了一个错误：

:3000/angular2/src/platform/browser/browser_adapter.js:76 

EXCEPTION: TypeError: Observable_1.Observable.forkJoin is not a function

下面是我的函数的剪切版本：

processStuff( inputObject ) {
  let _self = this;

  return new Observable(function(observer) {
    let observableBatch = [];

    inputObject.forEach(function(componentarray, key) {
      observableBatch.push(_self.http.get(key + '.json').map((res: Response) => res.json()));
    });

    Observable.forkJoin(
      observableBatch
    // );
    ).subscribe(() => {
      observer.next();
      observer.complete();
    });

  });
}

我的问题的根源是在继续之前要结束的循环：Angular2 Observable-如何在继续之前等待循环中的所有函数调用结束？

但是我还没有完全掌握使用数组和正确的语法来正确使用forkJoin。

我非常感谢你能提供的帮助。

thirdFunction() {
  let _self = this;

  return Observable.create((observer) => {
  // return new Observable(function(observer) {
    ...

    observer.next(responseargs);
    observer.complete();
  });
}

processStuff(inputObject) {
  let _self = this;
  let observableBatch = [];

  inputObject.forEach((componentarray, key) => {
    observableBatch.push(_self.thirdFunction().map((res: Response) => res.json()));
  });

  return Observable.forkJoin(observableBatch);
}

elsewhere() {
  this.processStuff(inputObject)
    .subscribe()
}

Answer 1

这里是一个使用Angular 12的工作演示。语法与公认的答案有很大的不同（不再可见）：

https://stackblitz.com/edit/angular-map-to-forkjoin?file=src/app/app.component.ts

注意：打开Developer Tools控制台，查看我正在做的事情的输出

首先，这将获取一个JSON项数组（在本例中是一个用户数组），并使用map方法将它们转换为单独的HTTP补丁调用。

  private mapCalls(users: any[]): Observable<any>[] {
    return users.map(user => {
      // Each User will be patched to the endpoint
      // None of these calls will be made until forkJoin is used
      return this.http.patch(
        `https://jsonplaceholder.typicode.com/users/${user.id}`,
        user
      );
    });
  }

现在这是一组可观测的数据forkJoin作为包装器添加，以便进行这些调用

return forkJoin(mappedCalls);

然后可以订阅最终结果，并将其输出为具有相同项计数的单个数组。

注意：如果forkJoin中有一个调用失败，那么它们都将失败。

Answer 2

您需要导入默认情况下未加载的运算符。这就是EXCEPTION Observable.xxxx不是函数通常的意思。您可以通过向引导程序添加完整的rxjs来导入所有运算符，例如：

import 'rxjs/Rx'

或通过导入特定运算符，在您的情况下：

import 'rxjs/add/observable/forkJoin'

关于你的代码的另一个观察/建议：试着坚持一种语法。你在混合es5，es6，打字稿...当它工作的时候，从长远来看只会让你困惑。此外，如果您刚刚开始使用可观察性，请尝试避免使用新的可观察性（），而是使用创建运算符；

processStuff( inputObject ) {
  let observableBatch = [];

  inputObject.forEach(( componentarray, key ) => {
    observableBatch.push( this.http.get( key + '.json').map((res: Response) => res.json()) );
  });

  return Observable.forkJoin(observableBatch);
}

elsewhere() {
  this.processStuff( inputObject )
    .subscribe()
}

最后，请参阅正确的文档-Angular2使用RxJS v5，您提供的链接是针对RxJS v4的。v5的文档仍然不完整，但您可以在许多源文件中找到描述。