RxJS - 最新更新


我们在本教程中使用 RxJS 版本 6。RxJS 通常用于处理响应式编程,并且更常与 Angular、ReactJS 一起使用。Angular 6 默认加载 rxjs6。

与版本 6 相比,RxJS 版本 5 的处理方式有所不同。如果将 RxJS 5 更新到 6,代码将会中断。在本章中,我们将看到处理版本更新的方式的差异。

如果您将 RxJS 更新到 6 并且不想更改代码,您也可以这样做,并且必须安装以下软件包。

npm install --save-dev rxjs-compact

该包将负责提供向后兼容性,旧代码将在 RxJS 版本 6 中正常工作。如果您想要进行与 RxJS 6 正常工作的代码更改,以下是需要完成的更改。

运营商、可观察物、主题的包进行了重组,因此主要变化发生在导入方面,如下所述。

运营商进口

根据版本 5,对于运算符,应包含以下导入语句 -

import 'rxjs/add/operator/mapTo'
import 'rxjs/add/operator/take'
import 'rxjs/add/operator/tap'
import 'rxjs/add/operator/map'

在 RxJS 版本 6 中,导入如下 -

import {mapTo, take, tap, map} from "rxjs/operators"

导入方法来创建 Observables

根据版本 5,在使用 Observables 时,应包含以下导入方法 -

import "rxjs/add/observable/from";
import "rxjs/add/observable/of";
import "rxjs/add/observable/fromEvent";
import "rxjs/add/observable/interval";

在 RxJS 版本 6 中,导入如下 -

import {from, of, fromEvent, interval} from 'rxjs';

观测值的导入

在 RxJS 版本 5 中,在使用 Observables 时,应包含以下导入语句 -

import { Observable } from 'rxjs/Observable'

在 RxJS 版本 6 中,导入如下 -

import { Observable } from 'rxjs'

导入主题

在 RxJS 版本 5 中,主题应包含如下 -

import { Subject} from 'rxjs/Subject'

在 RxJS 版本 6 中,导入如下 -

import { Subject } from 'rxjs'

如何在 RxJS 6 中使用运算符?

pipeline() 方法可用于创建的可观察对象。它是从 5.5 版本开始添加到 RxJS 中的。现在使用 pipeline(),您可以按顺序同时处理多个运算符。这就是 RxJS 版本 5 中运算符的使用方式。

例子

import "rxjs/add/observable/from";
import 'rxjs/add/operator/max'

let list1 = [1, 6, 15, 10, 58, 2, 40];
from(list1).max((a,b)=>a-b).subscribe(x => console.log("The Max value is "+x));

从 RxJS 5.5 版本开始,我们必须使用 pipeline() 来执行运算符 -

例子

import { from } from 'rxjs';
import { max } from 'rxjs/operators';

from(list1).pipe(max((a,b)=>a-b)).subscribe(x => console.log(
   "The Max value is "+x)
);

运营商更名

在包的重组过程中,一些运算符被重命名,因为它们与 javascript 关键字冲突或匹配。列表如下所示 -

操作员 重命名为
做() 轻敲()
抓住() 捕获错误()
转变() switchAll()
最后() 完成()
扔() 抛出错误()