RxJS Observable构造函数中回调内this关键字的行为解析

首先要明确：你看到的this: Observable<T>是TypeScript的类型注解，不是运行时需要传入的实际参数。它的作用是约束回调函数被调用时，this关键字的指向类型，和函数的实际参数数量无关。

核心原理 #

当你创建Observable并传入subscribe回调后，RxJS内部在调用这个回调时（比如当Observable被subscribe()订阅时），会通过Function.call()或Function.apply()把当前的Observable实例绑定为回调函数的this上下文。也就是说，这个this是RxJS帮你自动绑定好的，不需要你手动传入。

为什么示例里只写subscriber参数？ #

因为在大多数场景下，你不需要在回调里访问Observable实例本身，所以可以完全忽略this参数。TypeScript允许你只声明实际需要用到的参数——只要函数的签名和调用时传入的参数（这里是subscriber一个参数）兼容即可。

如果确实需要在回调里访问Observable实例，可以这样写：

const observable = new Observable(function(this: Observable<number>, subscriber) {
  // 这里的this会指向当前创建的Observable实例，TypeScript会提供正确的类型提示
  console.log('当前Observable实例:', this);
  subscriber.next(1);
});

注意这里不能用箭头函数，因为箭头函数的this是词法作用域捕获的，不会绑定RxJS传入的Observable实例，此时TypeScript的this类型注解也会失效。

和forEach的区别 #

数组的forEach方法，回调函数的this默认是全局对象（非严格模式）或undefined（严格模式），如果要指定this需要手动传入第二个参数。而RxJS的subscribe回调，this的指向是内部已经帮你绑定好的Observable实例，同时用TypeScript的this参数注解来明确类型，所以你不需要额外处理this的传递。

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