rxjs提前终止流？

Question

问题描述

比如

from('').pipe(a).pipe(b).pipe(c).pipe(d).subscribe(res,error,complete)

现在的需求：
如果在a阶段想结束流，或者让流跳过bcd，直接到subscribe里的res或者error，complete可以吗？
或者直接在a这个环节截断流，不往下执行

Answer 1

结束流的话,可以使用filter,通过设定条件,让满足条件的流继续往下游传,而不满足的就不会往下流传了.

要跳过某些步骤的话,可以通过mergeMap,然后在里面判断哪些流需要执行其他步骤,哪些流直接传递下去.当然也可以用其他的操作符达到效果,根据需要去选择,这里只是举个例子.

range(1, 10)
  .pipe(
    filter(v => v >= 3), // 当数字小于 3 的时候直接过滤掉不往下传
    mergeMap(v => {
      if (v % 2 === 0) { // 判断是否为偶数
        // 当数字为偶数时,直接返回包含这个数字的流
        return of(v)
      } else {
        // 当数字为奇数时,返回包含后续处理的流,相当于你的 bcd
        return of(v).pipe(map(v => v * -1))
      }
    }),
  )
  .subscribe(console.log)
// 输出:
// -3
// 4
// -5
// 6
// -7
// 8
// -9
// 10