RxJS中调用Subscription实例的next方法为何可正常执行？

这个问题确实挺绕的，我刚接触RxJS的时候也踩过类似的坑，来给你拆解清楚：

核心原因：实际返回的是「Subscriber实例」，而非单纯的Subscription #

你代码里subscribe()返回的变量sub，从TypeScript的类型提示看是Subscription，但运行时它其实是一个Subscriber类的实例。

在RxJS的内部实现里：

• Subscriber类是直接继承自Subscription的，所以它天生拥有Subscription的所有能力（比如unsubscribe取消订阅）；
• 同时Subscriber本身就自带next方法——这是它作为订阅者处理数据流的核心方法之一。

而Subject.subscribe()方法的内部逻辑，就是创建一个Subscriber实例，把你传入的回调绑定到这个实例上，然后返回它。只是TypeScript的类型声明把返回值标注成了更抽象的Subscription（因为外部代码通常只需要用到订阅管理的能力），这就造成了“类型和实际实例不匹配”的错觉。

为什么调用sub.next()能输出内容？ #

因为你订阅的是Subject，而Subscriber的next方法会直接把你传入的值，传递到你定义的console.log(data)回调里。不过这其实是个“意外可用”的用法——官方从来没推荐过这么写！

正确的写法提醒 #

这种写法属于滥用了RxJS的内部实现，后续版本的RxJS说不定就会调整，导致代码失效。而且从语义上来说，Subscription的职责是管理订阅生命周期（比如取消订阅），发送数据的职责应该交给Subject本身：

import { Subject } from 'rxjs';
const subject = new Subject();
// 保存订阅实例用来取消订阅
const sub = subject.subscribe((data) => {
  console.log(data);
});
// 用Subject本身的next发送数据
subject.next('Hello World');

内容来源于stack exchange