rxjsを使ってasync reduceまたはflatReduceを行う方法

Question

こんにちは、前任者の結果に応じて、それぞれ一連のajaxリクエストを行いたいと思います。

var urls = ["http://example.org/foo","http://example.org/bar", "..." ] 

Rx.Observable 
.from(urls) 
.reduce((response, url, idx, source)=>{ 

    return Rx.DOM.ajax({ 
    url: url+'?param='+ response.yxz, //append some results to the next request 
    responseType: 'json' 
    }).map(data=>data.response) 

},{yxz:0}) 
    .subscribe(... 

でも減らすためのアキュムレータは、「真の」値が返されることを想定しています

私の考えでは、このようなURLのリストを削減することでした。

このような方法はありますか？flatReduce電話をかけますか？

Answer 1

すべての結果を累積したくないため、減らす必要はありません。

あなたはここに再帰的に考える必要があります。

function tail(list) { 
    return list.splice(-1, 1) 
} 


function request(urls, param) { 
    if (urls.length <= 0) return param; 
    return Rx.DOM.ajax({ 
    url: urls[0] + '?param=' + param, 
    responseType: 'json' 
    }) 
    .map(data => data.response.xyz) 
    .flatMap(response => request(tail(urls), response)); 
} 


request(["http://example.org/foo", "http://example.org/bar", "..."], 0) 
    .subscribe(...) 

Answer 2

私はこれに新たなんだとまったく同じことを思っていました。私が思いついた解決策ではなくArray.reduceメソッドを使用していた：

var urls = ["http://example.org/foo","http://example.org/bar", "..." ] 

urls.reduce((observable, url) => { 

    return observable.flatMap(
     (response) => { 

      return Rx.DOM.ajax({ 
       url: url+'?param='+ response.yxz, //append some results to the next request 
       responseType: 'json' 
      }) 
      .map(data=>data.response); 
     } 

}, Observable.of({yxz:0})) 
.subscribe(...