javascript - 如何在仅在运行时知道 N 的情况下将 flatMap 运算符链接到可观察对象 N 次？

Question

我遇到了一种情况，我基本上需要做类似下面的事情。

observableFoo
.flatMap(bar(param[0]))
.flatMap(bar(param[1]))
//...
.flatMap(bar(param[N]))

function bar(param){
  var fn = function(...){
     // return some observable depending on param
  }
  return fn;
}

其中 N 仅在运行时已知。我怎样才能以“功能方式”实现它而不诉诸命令式for循环或一些可变变量？

Answer 1

一种实用的方法是折叠param数组（使用 JavaScript 的.reduce方法）：

param.reduce(function(o, p) {
    return o.flatMap(bar(p)); // probably inline the bar call
}, observableFoo);

Answer 2

var i = 0;
observableFoo
  .expand(function (x) { 
    return Rx.Observable.just(x).flatMap(bar(param[i++]));
  })
  .take(N)

查看expand的文档，并以这个JSFiddle为例。这里的ivar 确实是一个可变变量，但只需要判断它是有问题还是无害。