在rxjs传递复合数据可观察链

Question

我有一个代码块，在那里我打电话观测链中，像这样：

getData().flatMap(results => { 
    return callNextDataMethod(results); 
} 
.flatMap(results2 => { 
    // next operation and so forth 
}) 

现在，我明白flatMap会让我通过的结果先前可观察到下一个。然而，我需要的是既要做到这一点，又要在第一次通过结果。假设我对getData中返回的数据执行了一些清理，验证等操作，并且我希望将这些数据传递给链中的所有flatMap调用。 rxjs中是否有一个运算符会为我执行此操作？

感谢

Answer 1

可以使用map操作由flatMap投影功能与观察到的结果收到的参数组合：

getData() 
    .flatMap(data => 
    getMoreData(data).map(moreData => ({ data, moreData })) 
) 
    .flatMap(({ data, moreData }) => 
    getEvenMoreData(moreData).map(evenMoreData => ({ data, moreData, evenMoreData })) 
) 
    .flatMap(({ data, moreData, evenMoreData }) => 
    ...