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

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);