来自可观察数组的MergeMap

TLDR：工作示例在该问题的最后一个代码块中。查看@ bryan60答案，使用concat而不是的工作示例mergeMap。

我正在尝试顺序运行多个远程请求，但仅执行第一个可观察到的请求。

请求的数量各不相同，因此我无法在将可观察对象彼此嵌套的情况下进行躲避的解决方案。

我正在使用以下代码：

const observables = [
  observable1,
  observable2,
  ...
];

from(observables).pipe(
  mergeMap(ob=> {
    return ob.pipe(map(res => res));
  }, undefined, 1)
).subscribe(res => {
  console.log('Huzzah!');
})

过去（rxjs 5.5）Ive使用以下方法：

let o = Observable.from(observables).mergeMap((ob) => {
  return ob;
}, null, 1);

o.subscribe(res => {
  console.log('Huzzah!');
})

我不确定自己在做什么错，有人可以阐明吗？

另一个要求是仅打印“ Huzzah！” 一旦完成所有请求，而不是每个可观察者。

编辑：

undefined从我的原始代码中删除将使其起作用，但是还有另一个问题导致仅第一个可观察对象被执行。

我正在使用Angular的HttpClient远程请求。我的可观察代码如下所示：

const observables = [];

// Only the first observable would be executed
observables.push(this.http.get(urla));
observables.push(this.http.get(urlb));
observables.push(this.http.get(urlc));

向.pipe(take(1))每个可观察值添加结果将执行每个可观察值：

const observables = [];

// All observables will now be executed
observables.push(this.http.get(urla).pipe(take(1));
observables.push(this.http.get(urlb).pipe(take(1));
observables.push(this.http.get(urlc).pipe(take(1));

我最终使用的代码按顺序执行所有可观察对象，并且仅触发Huzzah!一次：

const observables = [];

observables.push(this.http.get(urla).pipe(take(1));
observables.push(this.http.get(urlb).pipe(take(1));
observables.push(this.http.get(urlc).pipe(take(1));

from(observables).pipe(
  mergeMap(ob=> {
    return ob.pipe(map(res => res));
  }, 1),
  reduce((all: any, res: any) => all.concat(res), [])
).subscribe(res => {
  console.log('Huzzah!');
})

感谢@ bryan60帮助我解决了这个问题。