如何从rxjs访问以前的mergeMap值

Question

我正在学习使用RXJS。在这个场景中，我使用rxjs链接了一些异步请求。在上一次合并地图时，我希望能够访问第一个合并地图的参数。我已经探索了使用Global或with Latest的选项，但这两个选项似乎都不适合这里。

const arraySrc$ = from(gauges).pipe(
    mergeMap(gauge => {
      return readCSVFile(gauge.id);
    }),
    mergeMap((csvStr: any) => readStringToArray(csvStr.data)),
    map((array: string[][]) => transposeArray(array)),
    mergeMap((array: number[][]) => forkJoin(uploadToDB(array, gauge.id))),
    catchError(error => of(`Bad Promise: ${error}`))
  );

readCSVFile是一个异步请求，它返回一个可观察到的从远程服务器读取CSV。

readStringToArray是另一个异步请求，它返回一个可观察的字符串，以将字符串转换为数组

transposeSarray只进行转置

uploadToDB是异步DB请求，需要gague。来自第一个合并映射的id。

我怎么才能得到那个？接受一些关于为什么我这样做不好的建议会很棒。

目前，我只是一层一层地传递身份证，但感觉不正确。

const arraySrc$ = from(gauges).pipe(
    mergeMap(gauge => readCSVFile(gauge.id)),
    mergeMap(({ data, gaugeId }: any) => readStringToArray(data, gaugeId)),
    map(({ data, gaugeId }) => transposeArray(data, gaugeId)),
    mergeMap(({ data, gaugeId }) => uploadToDB(data, gaugeId)),
    catchError(error => of(`Bad Promise: ${error}`))
  );

Answer 1

你为什么不干脆这样做呢？

const arraySrc$ = from(gauges).pipe(
    mergeMap(gauge => readCSVFile(gauge.id).pipe(
         mergeMap((csvStr: any) => readStringToArray(csvStr.data)),
         map((array: string[][]) => transposeArray(array)),
         mergeMap((array: number[][]) => forkJoin(uploadToDB(array, gauge.id)))
    )),
    catchError(error => of(`Bad Promise: ${error}`))
);

您还可以在函数中包装内部可见：

uploadCSVFilesFromGaugeID(gaugeID): Observable<void> {
     return readCSVFile(gaugeID).pipe(
         mergeMap((csvStr: any) => readStringToArray(csvStr.data)),
         map((array: string[][]) => transposeArray(array)),
         mergeMap((array: number[][]) => forkJoin(uploadToDB(array, gaugeID))
     );
}

为了在最后做到这一点：

const arraySrc$ = from(gauges).pipe(
    mergeMap(gauge => uploadCSVFileFromGaugeID(gauge.id)),
    catchError(error => of(`Bad Promise: ${error}`))
);