在上一篇文章中，我们了解了 RxJS 中的基本概念和操作符，以及如何使用 RxJS 来处理异步数据流。在本篇文章中，我们将重点介绍如何创建 Observables。
什么是 Observables？
Observables 是 RxJS 中最重要的概念之一。简单来说，Observables 就是一个可以发出多个值的数据流。这些值可以是任何类型的，比如数字、字符串、对象等等。
Observables 有三个关键特点：
发出多个值：一个 Observable 可以发出多个值，而不仅仅是一个。
异步处理：Observables 可以用来处理异步数据流，比如从服务器获取数据或者响应用户输入。
取消订阅：Observables 可以被订阅，但是也可以被取消订阅。当一个 Observable 被取消订阅时，它就不再发出新的值。
如何创建 Observables？
在 RxJS 中，有多种方式可以创建 Observables。下面我们将介绍其中的几种。
使用 of() 方法创建 Observables
of() 方法可以用来创建一个 Observable，这个 Observable 会在订阅时立即发出一组预定义的值，然后就完成了。
示例代码：
import { of } from 'rxjs';
const source = of(1, 2, 3);
source.subscribe(value => console.log(value));运行结果：
1 2 3
使用 from() 方法创建 Observables
from() 方法可以用来将一个数组、类数组对象、Promise 对象、迭代器对象或者字符串转换成一个 Observable。
示例代码：
import { from } from 'rxjs';
const array = [1, 2, 3];
const source = from(array);
source.subscribe(value => console.log(value));运行结果：
1 2 3
使用 create() 方法创建 Observables
create() 方法是 RxJS 中最灵活的创建 Observable 的方式。它可以用来创建任何类型的 Observable，包括异步 Observable。
示例代码：
// javascriptcn.com 代码示例
import { Observable } from 'rxjs';
const source = new Observable(observer => {
observer.next(1);
observer.next(2);
observer.next(3);
observer.complete();
});
source.subscribe(value => console.log(value));运行结果：
1 2 3
在这个例子中，我们手动创建了一个 Observable，并在其中发出了三个值。当 Observable 完成时，我们调用了 observer.complete() 方法。
使用 interval() 方法创建 Observables
interval() 方法可以用来创建一个 Observable，这个 Observable 会在每个固定的时间间隔发出一个数字。
示例代码：
import { interval } from 'rxjs';
const source = interval(1000);
source.subscribe(value => console.log(value));运行结果：
0 1 2 3 ...
在这个例子中，我们创建了一个每隔一秒钟发出一个数字的 Observable。
总结
在本文中，我们介绍了 Observables 的基本概念和特点，并详细介绍了如何使用 RxJS 中的不同方法来创建 Observables。创建 Observables 是 RxJS 中最基础的操作之一，掌握好这个知识点将为我们后续的 RxJS 开发带来很大的帮助。
来源：JavaScript中文网 ，转载请注明来源 本文地址：https://www.javascriptcn.com/post/655456e9d2f5e1655de0c045