RxJS中Observable并非真异步？实例输出顺序存疑

你遇到的问题核心是：RxJS的Observable并非天生都是异步的，of操作符创建的流属于同步发射数据的类型，所以订阅回调会在主线程中立即执行，导致输出顺序为1. before subscribe→2. in subscribe→3. after subscribe。

具体原因： #

• of操作符的实现逻辑是：当订阅发生时，会同步地把传入的所有值依次推送给订阅者，不会将任务放入宏任务或微任务队列等待后续执行。
• 只有部分RxJS操作符是异步的（比如timer、interval、fromPromise等），这些操作符会借助浏览器的事件循环来延迟执行回调。

对比异步场景的示例： #

如果把of换成timer(0)（一个延迟0毫秒的异步操作符），代码执行顺序就会变成你预期的异步模式：

<script type="module">
import { timer } from 'https://dev.jspm.io/rxjs@6';

console.log("1. before subscribe");
timer(0).subscribe(() => {
    console.log("2. in subscribe");
});
console.log("3. after subscribe");
</script>

输出会是：

1. before subscribe
3. after subscribe
2. in subscribe

总结： #

RxJS的设计是灵活的，它支持同步和异步两种数据流场景。判断一个Observable是同步还是异步，取决于具体操作符的实现逻辑，不能默认认为所有Observable都是异步的。

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