angular - 为什么不可能返回 forkJoin？

Question

我不明白为什么我可以这样做

ForkJoin(service.Obs1(), service.Obs2()).subscribe

但是如果我重构我的代码，以便我向我的服务类添加一个返回 ForkJoin(this.Obs1(), this.Obs2()) 的方法，例如

updateWhatever(): Observable<[string, string]> {
return forkJoin([
  this.Obs1(),
  this.Obs(2)
]);}

然后如果我执行 service.updateWhatever().subscribe(res =>//handle res[].，它会抛出错误

You provided an invalid object where a stream was expected. You can provide an Observable, Promise, Array, or Iterable

为什么这行不通？人们应该能够以这种方式进行重构。我错过了什么？我意识到它返回了一组可观察值，但为什么函数调用不处理这个？

也许我的问题是，如何处理返回 forkJoin 的方法？

Answer 1

特定于 Rxjs 5 或更早版本:

forkJoin 不期望 Observable 的 Array。它需要 SubscribableOrPromise 类型的来源

你必须这样做:

updateWhatever() {
  return forkJoin(
    this.Obs1(),
    this.Obs(2)
  );
}