RxJS:有没有像mergeScan一样的运算符，但当外部流发出时，只是取消订阅内部流

在RxJS中，虽然没有与mergeScan完全相同的运算符，但可以使用其他运算符来实现类似的功能。当外部流发出时，取消订阅内部流的方式可以通过使用takeUntil运算符来实现。

takeUntil运算符接收一个notifier流作为参数，当notifier流发出值时，它会立即完成并取消订阅源流。因此，可以将外部流作为notifier流传递给takeUntil运算符，以达到在外部流发出时取消订阅内部流的效果。

下面是一个示例代码：

import { interval, of, merge } from 'rxjs';
import { mergeScan, takeUntil } from 'rxjs/operators';

const outer$ = interval(1000); // 外部流，每秒发出一个值
const inner$ = of('A', 'B', 'C'); // 内部流，发出三个值

const result$ = outer$.pipe(
  mergeScan((acc, curr) => {
    // 在这里处理内部流的订阅和取消订阅逻辑
    console.log('外部流发出值:', curr);
    
    if (curr === 3) {
      // 当外部流发出值为3时，取消订阅内部流
      return of(acc, 'CANCEL');
    }
    
    // 继续订阅内部流
    return inner$;
  }, ''),
  takeUntil(outer$) // 当外部流发出时，取消订阅内部流
);

result$.subscribe(console.log);

在上面的代码中，mergeScan运算符用于处理内部流的订阅和取消订阅逻辑。当外部流发出值为3时，通过返回of(acc, 'CANCEL')来取消订阅内部流。takeUntil运算符用于在外部流发出时取消订阅内部流。

这样，当外部流发出值为3时，内部流将被取消订阅，不再发出值。