RxJS是否存在订阅时触发的initialize管道操作符？

RxJS官方并没有内置名为initialize()的操作符，但你可以通过现有基础操作符轻松实现完全等效的功能，让初始化和清理逻辑对称封装在Observable的管道中。

方法一：用defer()实现核心逻辑 #

defer()操作符的特性是每次订阅时才会执行内部的Observable工厂函数，正好用来触发初始化逻辑。结合finalize()就能实现对称的生命周期管理：

// 通用场景
const newObservable = defer(() => {
  setup_things(); // 订阅时执行初始化
  return observable;
}).pipe(
  finalize(() => some_cleanup()) // 完成/出错时执行清理
);

// 加载提示场景
const newObservable = defer(() => {
  loading = true;
  return observable;
}).pipe(
  finalize(() => loading = false)
);

这样每次订阅newObservable时，都会自动先执行初始化代码，无需在订阅前手动调用，完美解决你觉得写法不对称的问题。

方法二：封装成自定义操作符（复用更方便） #

如果需要在多个地方使用，可以把这个逻辑封装成自定义操作符，完全贴合你想要的initialize()调用方式：

import { Observable, defer, MonoTypeOperatorFunction } from 'rxjs';

function initialize<T>(initFn: () => void): MonoTypeOperatorFunction<T> {
  return (source: Observable<T>) => defer(() => {
    initFn();
    return source;
  });
}

之后就能像你最初设想的那样链式调用：

const newObservable = observable.pipe(
  initialize(() => setup_things()),
  finalize(() => some_cleanup())
);

为什么官方不内置这个操作符？ #

RxJS的设计理念是提供基础操作符让用户灵活组合，defer()已经能覆盖这类初始化场景，不需要额外添加专门的操作符。这种组合方式反而更灵活，你可以根据需求调整初始化逻辑的时机和内容。

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