使用内部可观察谓词的管道过滤器

Question

我正试图了解 RxJS。特别是我有一种情况，我试图通过一个过滤器从外部可观察到的排放，该过滤器具有一个内部可观察谓词，该谓词取决于外部可观察的输出。举例：

outerObs.pipe(
    filter(x => myPredicate(x))
).subcribe()

其中mypredicate 是一个返回Observable<boolean> 的函数。显然，上述内容不起作用，因为filter 运算符期望boolean 而不是Observable<boolean>。有没有一种很好的管道方式来做到这一点？我试过查看 withLatestFrom 和 mergeMap 运算符，但似乎没有任何效果。

Answer 1

您需要使用*Map 运算符之一：mergeMap、exhaustMap、switchMap 或 concatMap

这是一个带有concatMap 的示例，它将保证初始发射顺序：

outerObs.pipe(
  concatMap(x => myPredicate(x).pipe(
    filter(subx => subx == true), // filter by sub value
    mapTo(x)                      // map sub value back to outer value
  ))
).subcribe()

查看此mergeMap vs exhaustMap vs switchMap vs concatMap比较以选择合适的。

希望对你有帮助