为什么我们需要使用flatMap？

user233232 发表于 Javascript

299

用户233232：

我开始使用RxJS，但我不明白为什么在此示例中我们需要使用类似flatMapor 的函数concatAll；数组的数组在哪里？

var requestStream = Rx.Observable.just('https://api.github.com/users');

var responseMetastream = requestStream
  .flatMap(function(requestUrl) {
    return Rx.Observable.fromPromise(jQuery.getJSON(requestUrl));
  });

responseMetastream.subscribe(url => {console.log(url)})

如果有人可以直观地解释正在发生的事情，那将非常有帮助。

用户3743222：

当我开始看时，Rxjs我也偶然发现了那块石头。帮助我的是以下几点：

来自reactx.io的文档。例如，对于flatMap：http : //reactivex.io/documentation/operators/flatmap.html
来自rxmarbles的文档：http： //rxmarbles.com/ 。您不会在flatMap那找到，必须去看看mergeMap（另一个名字）。
您缺少的Rx简介：https : //gist.github.com/staltz/868e7e9bc2a7b8c1f754。它解决了一个非常相似的例子。特别是它解决了一个承诺类似于仅发出一个值的可观察对象的事实。
最后查看来自RxJava的类型信息。未键入Javascript在这里没有帮助。基本上，if Observable<T>表示一个可观察对象，该对象可推入T类型的值，然后flatMap将type函数T' -> Observable<T>作为其参数，然后返回Observable<T>。map接受type函数T' -> T并返回Observable<T>。

回到您的示例，您有一个从URL字符串产生promise的函数。所以T' : string和T : promise。而从我们之前说的promise : Observable<T''>，所以T : Observable<T''>，有T'' : html。如果将那个Promise Production函数放入中map，您将获得所需的Observable<Observable<T''>>时间Observable<T''>：您希望可观察对象发出html值。flatMap之所以这样称呼，是因为它会使（）的结果变平（除去可观察层）map。根据您的背景，这对您来说可能是中文，但是通过输入信息和来自此处的图纸，一切对我来说都非常清楚：http : //reactivex.io/documentation/operators/flatmap.html。