在 RxJs 中继续跟踪"original"项目



我需要访问流的"原始"值。

我的用例:

  1. URL的迭代列表。
  2. 请求每个URL。
  3. 处理响应,在这一点上,我还需要第一个"迭代"中的URL。

示例代码:

const Rx = require('rxjs');
const request = require('request');
// my request method in Rx version
const req = Rx.Observable.bindNodeCallback(request);
const list = [/*list of URLs*/];
Rx.Observable.from(list)
    .flatMap(req) // eq to: .flatMap(url => req(url))
    .map(response => {
        // here I need the response object
        // and the URL I used to request it (the "original" value).
    });

有什么想法吗?:)

.flatMap(
  url => doRequest(url),
  (url, res) => ({ url, res }) 
)

最新更新