什么是 @reactivex/rxjs
@reactivex/rxjs是一个基于观察者模式的JavaScript库，可以用于异步和基于事件的应用程序创建更加简单和可读的代码。其主要特点为：
- 支持事件的组合和转换，可以使用简单的语法将多个事件合并为一个。
- 可以轻松地将异步和同步代码结合使用，并提供了捆绑和取消订阅的功能。
- 可以用于处理实时数据流，例如使用WebSockets从服务器接收消息。
它是ReactiveX家族库的一部分，包括其他语言的库，如RxJava、RxSwift等。
如何使用 @reactivex/rxjs
安装
@reactivex/rxjs可以通过在终端中运行以下命令来安装：
npm install --save rxjs
这将从npm注册表下载库，并将其添加到项目依赖项中。
引入
在JavaScript或TypeScript文件中使用该库需要先引入：
import { Observable } from 'rxjs';这里我们只引入其中的Observable，因为Observable是 RxJS 中最核心的概念和功能。
创建 Observable
Observable是RxJS中最核心的概念和功能，它可以帮助我们处理异步和基于事件的流数据。Observable实例包含一个subscribe方法，该方法接受三个参数：
- next： 此方法接受一个数据项，如果有多个数据项则可以多次调用此方法，每个数据项调用一次。
- error： 异常处理器函数，当Observable出现异常时会被调用。
- complete：当Observable完成时会被调用。
让我们来看一个最基本的Observable：
const observable = new Observable(observer => {
observer.next('Hello');
observer.next('RxJS');
observer.complete();
});这个Observable将发送两个数据项，一个是字符串“Hello”和另一个是字符串“RxJS”，最后调用完了“complete”。
订阅 Observable
创建 Observable 后，我们需要订阅它才能开始接收数据。这可以通过在Observable 实例上调用subscribe方法来完成，该方法需要自己处理每个数据项：
observable.subscribe({
next: data => console.log(data),
error: err => console.log(err),
complete: () => console.log('Observable completed')
})这里，我们使用了一个匿名对象作为订阅器，使用next方法来打印每个接收的数据项，error方法来处理异常情况，complete方法来表明Observable已经完成。
操作符
Observable 的一个最重要的功能是能够使用操作符来转换，合并或过滤数据流。RxJS提供了多个操作符，以下是几个常用的操作符：
-- -------------------- ---- -------
------ - -- - ---- -------
------ - ---- ------- -------- - ---- -----------------
----- -- --
------
------- -- --- - ---
---------- -- --- - ---
------------ -- ------ - ---
-
-----------------------这个例子中，我们通过of方法创建了一个Observable，接着使用map操作符来将所有值乘以2，然后我们使用filter操作符来过滤小于或等于3的值，并使用mergeMap来将每个值后增加1。
这个流最后打印的结果是：
3 5
总结
@reactivex/rxjs是一个非常实用的JavaScript库，可以帮助我们更简单、更容易的处理异步和基于事件的应用程序。创建Observable并使用它们需要一些学习，但一旦你熟悉了RxJS的核心概念，你就可以使用它们更加轻松地编写复杂的应用程序。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/92589