RxJS中EMPTY与finalize结合不触发问题咨询及代码示例

流程拆解 #

你的代码逻辑里有个关键误区：finalize是在整个订阅的Observable完成或出错时才会触发，而非内部某个子Observable完成就执行。具体执行流程如下：

1. subject$.next(null)触发流的执行
2. 第一个tap执行，打印tap1
3. switchMap切换到EMPTY，EMPTY确实会立即发送完成通知，但这个完成仅属于switchMap内部的子Observable，不会让源subject$完成
4. 因为源subject$始终处于活跃状态（未调用complete()），整个订阅的Observable并没有结束，所以finalize不会执行
5. 第二个tap没触发是符合预期的，因为EMPTY不会发射任何数据

实现方案 #

要让finalize触发，只需让整个订阅的Observable完成即可，有两种常用方式：

方式一：让源Subject发送完成通知 #

在调用next后手动调用complete()，让源流结束：

const subject$ = new Subject();

subject$
  .pipe(
    tap(() => console.log('tap1')),
    switchMap(() => EMPTY),
    tap(() => console.log('tap2')),
    finalize(() => console.log('finalize')),
  ).subscribe();

subject$.next(null);
subject$.complete(); // 新增该行，让源流完成

方式二：用take(1)截断流 #

如果不想让源subject$本身完成，可在管道中加入take(1)，仅处理第一个值后就让整个订阅流完成：

const subject$ = new Subject();

subject$
  .pipe(
    take(1), // 新增该行，仅处理第一个发射值后结束流
    tap(() => console.log('tap1')),
    switchMap(() => EMPTY),
    tap(() => console.log('tap2')),
    finalize(() => console.log('finalize')),
  ).subscribe();

subject$.next(null);

两种方式都能得到你期望的输出：

tap1
finalize

内容的提问来源于stack exchange，提问作者Mirco