先拆解super()的调用逻辑 #

首先你要明确：Rx.Observable的构造函数本身就是接受一个**订阅函数（subscribe function）**作为参数的——这个函数会在Observable被订阅时执行，参数就是订阅它的observer对象。

看你的代码：

class MyObservable extends Rx.Observable {
  constructor(initialValue) {
    super((observer) => {
      observer.next(initialValue);
      this.observer = observer;
    });
  }
}

• 这里的super()不是无参调用，而是把一个箭头函数传递给了父类Rx.Observable的构造函数，以此完成父类实例的初始化。
• 当MyObservable的实例被订阅时（比如new MyObservable(1).subscribe(...)），这个传入的箭头函数就会触发执行：
  1. 立刻调用observer.next(initialValue)，把构造时传入的初始值推送给订阅者；
  2. 把当前的observer保存到子类实例的this.observer属性中。

为什么视频说这不是扩展Observable的良好方式 #

这段代码存在几个关键问题，也是RxJS官方不推荐直接继承Observable类的核心原因：

• 多订阅者冲突：一个Observable可以被多个观察者订阅，每次订阅都会执行这个订阅函数。你把observer保存到this.observer里，后续的订阅会直接覆盖之前的实例，导致只有最后一个订阅者能收到后续的通知（如果你的代码后续有调用this.observer.next的话）。
• 耦合度高，维护性差：RxJS的Observable内部实现可能会随版本更新变化，直接继承它会让你的代码和RxJS的内部细节深度绑定，后续版本升级或迁移很容易出问题。RxJS更推荐用操作符或工厂函数来创建Observable，而非继承。
• 缺少清理逻辑：标准的订阅函数应该返回一个清理函数，用于在订阅取消时释放资源（比如定时器、未完成的网络请求等）。这段代码没有做这件事，如果后续有需要清理的资源，会导致内存泄漏。

更合适的替代方案 #

如果你想创建一个能推送初始值的Observable，完全不需要继承，用RxJS提供的API就能轻松实现：

方案1：使用Observable.create（灵活支持自定义逻辑） #

const createMyObservable = (initialValue) => {
  return Rx.Observable.create((observer) => {
    // 推送初始值
    observer.next(initialValue);
    
    // 可选：添加清理逻辑，订阅取消时自动执行
    return () => {
      console.log('订阅已取消，开始清理资源');
    };
  });
};

// 使用示例
const myObs = createMyObservable(100);
myObs.subscribe(val => console.log(val)); // 输出100

方案2：使用of操作符（仅推送初始值的简单场景） #

如果你的需求只是推送一个初始值，直接用of操作符会更简洁：

const createMyObservable = (initialValue) => Rx.Observable.of(initialValue);

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