Rxjsはobservableが作成された場所のコンテキストをバインドします

Question

私はループ内で作成されたobservablesの配列を持っています。そして、mergeを使用してこれらの観測値をすべてマージし、マージした観測値にサブスクライブしました。私はそれがどこで作成されたか（ループ内で）観測可能なコンテキストを取得する方法を見つけることができませんでした。 @martinは、この結合し、何の問題私が解決しようとしていますので、私は本当の問題を説明することを目的について尋ねられたので、ここではコード

let observable = Rx.Observable.bindNodeCallback(request); 
let streams = _(['a', 'b', 'c', 'd']) 
.someMoreLodashStuff() 
.map(val => { 
    // HERE SOMEHOW I WANT TO BIND CONTEXT (e.g. loop val), 
    // SO THAT SUBSCRIBER CAN KNOW THE EXACT LOOP STATE 
    // WHEN RECEIVING RESULT 
    return observable(mutate(val)) 
}) 
.value(); 

Rx.Observable 
.merge(...streams) 
.subscribe(
    (res) => { 
    // HERE I WANT TO GET CONTEXT (e.g. val) 
    }, (err) => { 
    // HERE I WANT TO GET CONTEXT (e.g. val) 
    }, 
() => { 
    //on complete stuff 
    }); 

更新（@martinで尋ねたとして）

です。

Puposeと本当の問題

私はそのタイトルを取得し、HTMLでそれらをレンダリングして戻ってユーザーにHTMLを返し、（クエリのparamsとして渡された）ウェブサイトのリストをクロールしようとしています。これは私のopen source repoの一部で、node.jsのコールバック、async.jsの滝と約束を使ってこの正確な問題を解決しました。今rxjsを使ってそれを解決します。さまざまな非同期技術を学ぶための単なる方法です。これは、この問題

Answer 1

を解決するためにrxjsを使用して、あなたがマージされた入力+出力状態を含むタプルを作成するためにresultSelector機能を取るflatMapオーバーロードを使用することができ、入力状態への参照を保持する場合file from github repoです：

// given a function which can return the body of the page requested 
function doRequest(url) : Observable<string> 

const urls = Rx.Observable.from([a,b,c]) 
    .flatMap(
    a => doRequest(url), 
    (a,res) => ({ url: a, body: res}) 
) 
    .subscribe(resTuple => console.log(`url ${resTuple.url} returned ${resTuple.body}`)