RxJS 是一款强大的响应式编程库，它提供了许多创建 Observable 的方法。在本文中，我们将详细介绍 RxJS 中常用的 Observable 创建函数，以便您更好地理解和使用它们。
Observable 的概念
在深入了解 Observable 创建函数之前，让我们先快速回顾一下 Observable 的概念。Observable 是 RxJS 中的一个重要概念，它表示一个可观察的数据源，可以被订阅并用来处理异步事件。
Observable 有三种状态：等待状态、激活状态和完成状态。等待状态表示 Observable 已经被创建但是还没有被订阅，激活状态表示 Observable 已经被订阅并正在发出数据，完成状态表示 Observable 已经完成了数据的发射。
常用的 Observable 创建函数
RxJS 提供了许多创建 Observable 的方法，下面是一些常用的创建函数。
of()
of() 函数可以用来创建一个 Observable，它会发出一系列指定的值。例如：
import { of } from 'rxjs';
const source$ = of(1, 2, 3);
source$.subscribe(value => console.log(value));
// 输出：1
// 输出：2
// 输出：3from()
from() 函数可以用来创建一个 Observable，它会将一个数组、类数组对象、Promise 对象、迭代器对象或类似对象转换为 Observable。例如：
-- -------------------- ---- ------- ------ - ---- - ---- ------- ----- ----- - --- -- --- ----- ------- - ------------------- ----- ------- - ------------ ----------------------- -- -------------------- -- ---- -- ---- -- ---- ----- -------- - -------------- ------------------------ -- -------------------- -- ----
interval()
interval() 函数可以用来创建一个 Observable，它会发出一个连续的整数序列，每隔一段时间发出一个值。例如：
import { interval } from 'rxjs';
const source$ = interval(1000);
source$.subscribe(value => console.log(value));
// 输出：0
// 输出：1
// 输出：2
// ...timer()
timer() 函数可以用来创建一个 Observable，它会在指定的时间后发出一个值。例如：
import { timer } from 'rxjs';
const source$ = timer(1000);
source$.subscribe(value => console.log(value));
// 输出：0fromEvent()
fromEvent() 函数可以用来创建一个 Observable，它会从指定的 DOM 事件中发出值。例如：
import { fromEvent } from 'rxjs';
const button = document.getElementById('myButton');
const source$ = fromEvent(button, 'click');
source$.subscribe(event => console.log(event));ajax()
ajax() 函数可以用来创建一个 Observable，它会从指定的 URL 中获取数据。例如：
import { ajax } from 'rxjs/ajax';
const source$ = ajax('https://jsonplaceholder.typicode.com/posts');
source$.subscribe(response => console.log(response));create()
create() 函数可以用来创建一个自定义的 Observable。例如：
-- -------------------- ---- ------- ------ - ---------- - ---- ------- ----- ------- - --- ------------------- -- - ----------------- ----------------- ----------------- -------------------- --- ----------------------- -- -------------------- -- ---- -- ---- -- ----
总结
本文介绍了 RxJS 中常用的 Observable 创建函数，包括 of()、from()、interval()、timer()、fromEvent()、ajax() 和 create()。这些创建函数可以帮助我们快速创建 Observable，从而更好地处理异步事件。希望本文能够对您有所帮助。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/655b1efed2f5e1655d54b1d8