什么是 RxJS
RxJS 是一个用于处理异步和基于事件的编程的 JavaScript 库。它提供了一种更加简单和明确的方式来编写异步代码，使用可观察对象来管理异步数据流。
RxJS 的核心是 Observable，它是一个表示异步数据流的类。Observable 可以发送多个值，也可以在任何时候发出错误或完成信号。RxJS 还提供了很多操作符来处理 Observable，例如 map、filter、concat 等。
concat 操作符的作用
concat 操作符用于将多个 Observable 连接起来，依次发出它们的值。当一个 Observable 完成时，它会自动连接到下一个 Observable 并继续发出值，直到所有 Observable 都完成，最后发出完成信号。
concat 操作符的语法如下：
concat(...observables: Array<Observable>): Observable
其中，observables 是一个 Observable 数组，表示要连接的多个 Observable。
concat 操作符的示例
下面是一个使用 concat 操作符的示例：
import { concat, of } from 'rxjs'; const obs1 = of('hello'); const obs2 = of('world'); const obs3 = of('!'); concat(obs1, obs2, obs3).subscribe(value => console.log(value));
运行结果为：
hello world !
这里使用了 of 操作符创建了三个 Observable，分别发出字符串 'hello'、'world' 和 '!'。然后使用 concat 操作符连接这三个 Observable，最后订阅并输出它们发出的值。
concat 操作符的常见问题
问题一：concat 操作符只接收 Observable 类型的参数
concat 操作符只接收 Observable 类型的参数，如果传入的参数不是 Observable，会导致编译错误或运行时错误。
例如，下面的代码会导致编译错误：
import { concat } from 'rxjs'; const obs1 = 'hello'; const obs2 = 'world'; concat(obs1, obs2).subscribe(value => console.log(value));
正确的做法是使用 of 操作符将字符串转换为 Observable，例如：
import { concat, of } from 'rxjs'; const obs1 = of('hello'); const obs2 = of('world'); concat(obs1, obs2).subscribe(value => console.log(value));
问题二：concat 操作符可能导致内存泄漏
concat 操作符会将多个 Observable 连接起来，如果其中一个 Observable 没有完成，之后的 Observable 就永远不会被释放，可能导致内存泄漏。
为了避免内存泄漏，应该在每个 Observable 完成时手动取消订阅，例如：
-- -------------------- ---- ------- ------ - ------- -- - ---- ------- ----- ---- - ------------ ----- ---- - ------------ ----- ---- - -------- ------------ ----- ----------------- ----- ----- -- ------------------- --------- -- -- - ------------------------ --------------------------- - --- ----- ------------ - -----------------展开代码
这里使用 subscribe 方法的对象参数形式，传入了一个 complete 回调函数，在所有 Observable 完成时会调用该函数，并手动取消订阅。
总结
concat 操作符是 RxJS 中常用的操作符之一，用于将多个 Observable 连接起来，依次发出它们的值。使用 concat 操作符时需要注意传入的参数必须是 Observable 类型，同时可能会导致内存泄漏，需要手动取消订阅。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/6513874c95b1f8cacdbe5908
