相当于rxjs中循环中的循环

Question

相当于什么

array.forEach(element => {
  array.forEach(element2 => {
    //do something with element and element2
  });
});

在 rxjs 中？

目前我是这样“解决”的

switchMap(array => from(array).pipe(
  tap(element => {
    array.forEach(element2 => {
      //do something with element and element2
    })
  })
)

或

let globalArray = [...someObjects];

of(globalArray).pipe(
  mergeMap(array => array),
  tap(element => {
    globalArray.forEach(element2 => {
      //do something with element and element2
    })
  })
)

（在实际代码中globalArray是一个传递给函数的数组）

但这在 rxjs 中感觉不是正确的方法。

Answer 1

如果我正确理解您的问题，mergeMap 就是您要找的接线员。

mergeMap 需要一个返回 ObservableInput 的函数作为其第一个参数。数组是一个 ObservableInput。当返回一个 Array 时，mergeMap 将 Array 展平并将每个 Item 作为单独的通知发出。

所以下面的代码应该做你正在寻找的东西

of(arrayOfArraysOfNumbers)
.pipe(
  mergeMap(arrayOfArrays => arrayOfArrays),
  mergeMap(array => array)
)
.subscribe(console.log)

这里是example。

更新 - 相同的数组循环两次

如果你必须循环同一个数组两次，你可能会看到这样的东西

function closureForArray(arrayOfElements: Array<any>) {
  return from(arrayOfElements).pipe(
    mergeMap(e1 => from(arrayOfElements).pipe(
      map(e2 => ({e1, e2}))
    ))
  )
}

of(arrayOfElements)
.pipe(
  switchMap(closureForArray),
  map(({e1, e2}) => // do something with e1 and e2)
)

这里的基本思想是closureForArray 函数将arrayOfElements 保持在范围内，因此可以应用from RxJS 函数两次，一次运行第一个循环，另一个从第一个循环中运行第二个循环循环。

这里是updated example。