switchMap内部管道()与switchMap序列

Question

我不明白这两者之间是否有区别：

Observable.pipe( 
           switchMap((res) => {
             ...
            }),
            switchMap((res) => {
             ...
            })
);

这是：

Observable.pipe(
            switchMap((res) => {
             ...
            }).pipe(
                 switchMap((res) => {
                 ...
                 }),
            )
  );      

你能帮助我理解处理数据的方式是否有差异吗？

谢谢

Answer 1

正如它所写的，没有什么不同，但是如果您以后想要在管道中添加更多的项目，这可能很重要。例如，catchError --在第一种情况下，如果在管道的末尾添加它，那么它将捕获管道的任何一步引发的错误，但是在第二个例子中，您可以将它放在第一个管道中，在内部switchMap之后，它只会捕获内部操作中的错误。

哦，我刚读到@serrulien的评论，他说得对，你的第二个管子不能放在你放的地方，它应该放在第一个switchMap的体内，例如：

Observable.pipe(
  switchMap((res) => {
    return someObservable().pipe(
      switchMap((res) => {
        ...
      })
  })
);     

俗话说，剥猫皮的方法很多。

Answer 2

RxJS#pipe只是功能组合翻转。结果发现(和加法一样)，构图是相联的。

另外：

X+ (y + z) = (x + y) +z

关于组成：

X∘(y∘z) = (x∘y)∘z

这是什么意思？嗯，你可以把管道函数看作数学方程中的括号。

这些都是相同的表达式，只是在不同的位置加上括号：(由于管道化的RxJS运算符是关联的，所以括号在哪里并不重要)

// 1
stream.pipe(
  switchMap(/*...*/),
  concatMap(/*...*/),
  delay(/*...*/),
  toArray()
);

// 2
stream.pipe(
  switchMap(/*...*/),
  concatMap(/*...*/)
).pipe(
  delay(/*...*/),
  toArray()
);

// 3
stream.pipe(
  switchMap(/*...*/)
).pipe(
  concatMap(/*...*/)
).pipe(
  delay(/*...*/)
).pipe(
  toArray()
);