为什么通过数组声明的Observable不会自动扁平化？

问题核心原因解释 #

你遇到的问题本质是混淆了不同API的设计逻辑，以及RxJS中of和from的行为差异：

1. 为什么of()不会扁平化数组 #

RxJS的of的设计逻辑是：接收任意数量的参数，将每个参数作为独立的next值依次发射，不会对参数本身做展开处理。
你传入的是单个intArray数组参数，所以它只会发射整个数组对象，返回的Observable泛型自然是number[]，和你预期的行为不符。
你之所以觉得和Java Stream行为不同，是因为你用错了RxJS的对应方法：

• Java中Arrays.stream(数组)是专门针对数组的工具方法，会自动展开数组输出单个元素，和RxJS的from()行为完全一致。你把Arrays.stream和Java自带的Stream.of()搞混了——Java中如果写Stream.of(intArray)，得到的就是Stream<Integer[]>，和RxJSof(intArray)的行为完全相同。

如果你想得到Observable<number>，有两种写法：

// 写法1：用扩展运算符把数组展开为多个参数传入of
const intObs1: Observable<number> = of(...intArray);
// 写法2：直接用from方法，自动展开数组
const intObs2: Observable<number> = from(intArray);

2. 关于订阅类型的疑问 #

正常情况下，你订阅Observable<number[]>类型的对象，接收到的一定是number[]类型的完整数组，不可能出现单个number类型的值。如果你确实拿到了单个number，只可能是两种情况：

• 你在定义Observable和订阅之间加了concatAll/mergeMap之类的扁平化操作符，自动把数组拆成了单个元素发射
• 你实际创建Observable的时候错用了from而不是of，自己没有注意到

可以直接运行下面的代码验证默认行为：

import { of } from 'rxjs';

const intArray = [1, 2, 3, 4, 5];
const intObs: Observable<number[]> = of(intArray);
intObs.subscribe(val => {
  console.log(val); // 输出 [1,2,3,4,5]，类型为number[]
  console.log(Array.isArray(val)); // 输出 true
})

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