RxJS 是一款非常流行的函数式编程库，它提供了一组强大的工具来处理异步数据流。其中，Observable 是 RxJS 最核心的概念之一，它是一个能够表示任何类型的数据流并进行操作的类。
在本文中，我们将深入了解 RxJS 中的 Observable 包装类，包括如何创建 Observable 对象、如何定义 Observable 的行为以及如何将 Observable 与其他运算符一起使用。
创建 Observable 对象
RxJS 通过 Observable 类型来表示一个数据流，并提供了多种方式来创建 Observable 对象。
1. of 方法
of 方法可以将多个值转换为一个 Observable 对象，比如：
import { of } from 'rxjs';
const source = of(1, 2, 3);2. from 方法
from 方法可以将一个 Iterable、Promise 或类似数组的对象转换为 Observable 对象，比如：
import { from } from 'rxjs';
const source = from([1, 2, 3]);3. create 方法
create 方法可以手动创建一个 Observable 对象，比如：
-- -------------------- ---- -------
------ - ---------- - ---- -------
----- ------ - --- ------------------- -- -
-----------------
-----------------
------------- -- -
-----------------
--------------------
-- ------
---当我们调用 source.subscribe 时，传入了一个 Observer 对象，它包含三个回调函数：
next：每当 Observable 执行next方法时，都会调用该函数；error：每当 Observable 执行error方法时，都会调用该函数；complete：每当 Observable 执行complete方法时，都会调用该函数。
定义 Observable 的行为
通过定义 next、error 和 complete 回调函数，我们可以控制 Observable 的行为。
1. next 方法
next 方法用于向 Observer 发送新值，比如：
import { Observable } from 'rxjs';
const source = new Observable(observer => {
observer.next(1);
});2. error 方法
error 方法用于向 Observer 发送错误信息，比如：
import { Observable } from 'rxjs';
const source = new Observable(observer => {
observer.error(new Error('Something went wrong'));
});3. complete 方法
complete 方法用于告诉 Observer Observable 已经结束了，比如：
import { Observable } from 'rxjs';
const source = new Observable(observer => {
observer.complete();
});将 Observable 与其他运算符一起使用
一旦创建了 Observable 对象，我们可以通过一些运算符来对数据流进行处理。常用的运算符包括 map、filter、reduce 等。
1. map 运算符
map 运算符用于对 Observable 中的每个值进行映射操作，比如：
import { of } from 'rxjs';
import { map } from 'rxjs/operators';
const source = of('hello', 'world');
const example = source.pipe(map(value => value.toUpperCase()));在上面的代码中，我们通过 pipe 方法来将 map 运算符绑定到 source Observable 对象上。该运算符将 Observable 中的每个值转换为大写形式。
2. filter 运算符
filter 运算符用于对 Observable 中的每个值进行过滤操作，比如：
import { of } from 'rxjs';
import { filter } from 'rxjs/operators';
const source = of(1, 2, 3, 4, 5);
const example = source.pipe(filter(value => value % 2 === 0));在上面的代码中，我们通过 pipe 方法来将 filter 运算符绑定到 source Observable 对象上。该运算符将 Observable 中的每个值都按照给定的条件进行过滤操作，只保留偶数。
总结
在本文中，我们学习了 RxJS 中的 Observable 包装类，了解了如何创建和定义 Observable 对象以及如何将 Observable 与其他运算符一起使用。希望本文的内容能够帮助读者更好地理解 RxJS，更加顺利地应用于实际开发当中。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64a88b3348841e98945016c8