RxJS 是一个用于异步编程和数据流组合的库。其中的 of 操作符是 RxJS 中最简单、最基础的操作符之一，但却经常被用于创建 observable 对象，以便进行响应式编程。
本文将详细介绍 of 操作符的用法和实现，帮助读者更加深入地了解 RxJS 的基础知识，并能够在实际开发中利用其强大的功能。
of 操作符的概述
of 操作符创建一个 observable 对象，该对象将提供一个固定的数据序列。数据序列可以是任何数据类型，例如数字、字符串、布尔值、对象、数组等等。
of 操作符的语法为：
of(...values: T, scheduler: Scheduler): Observable<T>
其中，values 是需要发出的值，可以是多个值，也可以是一个数组，而 scheduler 是可选的调度器对象（用于控制并发），返回值是一个 observable 对象。
of 操作符的应用实例
下面是一个使用 of 操作符创建 observable 对象的例子：
import { of } from 'rxjs';
const source$ = of('a', 'b', 'c');
source$.subscribe(val => console.log(val));输出结果为：
a b c
在这个例子中，我们使用 of 操作符创建了一个 observable 对象，其中包含了三个字母字符。然后使用 subscribe() 方法订阅了这个 observable 对象，并在每次发出值时打印出该值。
我们也可以使用数组来传递多个值:
import { of } from 'rxjs';
const source$ = of(['a', 'b', 'c']);
source$.subscribe(val => console.log(val));输出结果为：
[a, b, c]
这里需要注意的是，使用 of 操作符时，如果只传递一个参数，则该参数就是整个值序列，而不是第一个值。
of 操作符的实现方式
of 操作符有多种实现方式。首先，我们可以直接使用 RxJS 的 of 操作符，其实现方式如下：
function of<T>(...args: Array<T | SchedulerLike>): Observable<T> {
const scheduler = popScheduler(args);
return fromArray(args, scheduler);
}该实现方式中，of 函数将传递的参数 args 与可选的调度器对象 scheduler 一起传递给 fromArray 函数，生成一个 observable 对象。
fromArray 函数的实现方式如下：
export function fromArray<T>(input: ObservableInput<T>, scheduler: SchedulerLike): Observable<T> {
if (!scheduler) {
return new ArrayObservable(input);
} else {
return new ScheduledArrayObservable(input, scheduler);
}
}该实现方式中，fromArray 函数会判断传递的调度器对象 scheduler 是否存在，如果存在，则返回一个 ScheduledArrayObservable 对象，否则返回 ArrayObservable 对象。
ScheduledArrayObservable 和 ArrayObservable 对象的实现方式如下：
-- -------------------- ---- -------
------ ----- --------------------------- ------- ------------- -
------- -------------------
---------- ------------- - ----------
------------------ ------ ----
----------- -------------- -
--------
----------- - --- -----------------------
-------------- - ----------
-
------ ---------------- ----
----------- --------------- ------------- -
------ --- ------------------------------- -----------
-
---------------------- --------------- ------------ -
------ -------------------------- ------------------------------------ -----------------
-
-
------ ----- ------------------ ------- ------------- -
------------------- ------ ---- -
--------
-
------ ---------------- ----- ------------- -
------ --- -----------------------
-
---------------------- -------------- -
----- - ----- - - -----
----- ------ - -------------
--- ---- - - -- - - ------ -- ------------------- ---- -
--------------------------
-
----------------------
-
-该实现方式中，ArrayObservable 对象是一个简单的 observable 对象，可以像其他的 observable 对象一样进行订阅和取消订阅操作。
而 ScheduledArrayObservable 对象则额外提供了一个额外的调度器功能，在处理异步数据流时非常方便。
总结
of 操作符是 RxJS 中的一个基础操作符，可以帮助开发者在实际开发中方便地创建 observable 对象，用于进行响应式编程。在使用该操作符时，需要注意对传递的参数进行处理，并选择适合当前场景的实现方式。
除了 of 操作符之外，RxJS 还提供了更多丰富的操作符和调度器，可以帮助开发者更加高效地进行异步编程和数据流组合。如果你希望深入了解 RxJS 的知识，可以继续学习其他操作符和调度器。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64560c17968c7c53b0955877