我每天都在使用的每天十个 RxJS 运算符

作者：佚名 2023-05-11 16:18:17开发 前端 作为一名 Angular 开发人员，您可能会发现以下 RxJS 运算符在您的都使日常开发中很有用。

作为一名 Angular 开发人员，用的S运您可能会发现以下 RxJS 运算符在您的算符日常开发中很有用：

01、map()：

此运算符用于转换可观察对象发出的每天值。它以一个函数作为参数，都使它接收发出的用的S运值作为输入并返回转换后的输出。返回的算符输出作为可观察对象的新值发出。例如，每天您可以使用 map() 将用户对象流转换为用户名流：

import {  map } from 'rxjs/operators';import {  UserService } from './user.service';constructor(private userService: UserService) { }this.userService.getUsers().pipe(  map(users => users.map(user => user.name))).subscribe(names => console.log(names));

02、都使filter()：

此运算符用于根据条件过滤掉 observable 发出的用的S运值。它以一个函数作为参数，算符它接收发出的每天值作为输入并返回一个布尔值。 

如果布尔值为 true，都使则发出该值，用的S运否则将其过滤掉。例如，您可以使用 filter() 只保留整数流中的偶数：

import {  filter } from 'rxjs/operators';import {  of } from 'rxjs';of(1, 2, 3, 4, 5, 6).pipe(  filter(num => num % 2 === 0)).subscribe(evenNum => console.log(evenNum));

03、switchMap()：

每当源可观察对象发出新值时，此运算符用于切换到新的可观察对象。它以一个函数作为参数，它接收发出的值作为输入并返回一个新的可观察值。 

最新的 observable 发出的值由返回的 observable 发出。 

例如，您可以使用 switchMap() 根据另一个可观察对象发出的 ID 获取用户数据：

import {  switchMap } from 'rxjs/operators';import {  UserService } from './user.service';constructor(private userService: UserService) { }this.userId$.pipe(  switchMap(userId => this.userService.getUser(userId))).subscribe(user => console.log(user));

04、catchError()：

此运算符用于处理可观察对象抛出的错误。它以一个函数作为参数，它接收错误作为输入并返回一个新的可观察对象。 

返回的可观察对象可以发出新值、完成或抛出另一个错误。例如，您可以使用 catchError() 重试失败的 HTTP 请求：

import {  catchError } from 'rxjs/operators';import {  HttpClient } from '@angular/common/http';constructor(private http: HttpClient) { }this.http.get('/api/data').pipe(  catchError(() => this.http.get('/api/fallbackData'))).subscribe(data => console.log(data));

05、tap()：

此运算符用于在不修改可观察对象的发射值的情况下执行副作用。它以一个函数作为参数，它接收发出的值作为输入并可以执行任何副作用。 

返回值被忽略，原始值不变。例如，您可以使用 tap() 来记录可观察对象发出的值：

import {  tap } from 'rxjs/operators';import {  of } from 'rxjs';of(1, 2, 3).pipe(  tap(value => console.log(`Emitting value: ${ value}`))).subscribe();

06、take()：

此运算符用于限制可观察对象发出的值的数量。这是一个例子：

import {  take } from 'rxjs/operators';import {  of } from 'rxjs';of(1, 2, 3, 4, 5).pipe(  take(3)).subscribe(value => console.log(value)); // output: 1, 2, 3

在此示例中，take(3) 用于将 of(1, 2, 3, 4, 5) 发出的数字流限制为前三个值。

07、debounceTime()：

此运算符用于按指定的时间量对值流进行去抖动。这是一个例子：

import {  debounceTime } from 'rxjs/operators';import {  fromEvent } from 'rxjs';const input = document.getElementById('input');fromEvent(input, 'input').pipe(  debounceTime(500)).subscribe(event => console.log(input.value));

在此示例中，debounceTime(500) 用于将来自输入元素的输入事件流去抖动 500 毫秒。这意味着如果用户快速连续键入，则只会记录 500 毫秒不活动后的输入值。

08、distinctUntilChanged()：

此运算符用于仅从值流中发出不同的值。这是一个例子：

import {  distinctUntilChanged } from 'rxjs/operators';import {  of } from 'rxjs';of(1, 2, 2, 3, 3, 3, 4).pipe(  distinctUntilChanged()).subscribe(value => console.log(value)); // output: 1, 2, 3, 4

在此示例中，distinctUntilChanged() 用于仅从 of(1, 2, 2, 3, 3, 3, 4) 发出的数字流中发出不同的值。

09、merge()：

此运算符用于将多个可观察对象合并为一个可观察对象。这是一个例子：

import {  merge } from 'rxjs';import {  interval } from 'rxjs';const obs1 = interval(1000);const obs2 = interval(2000);merge(obs1, obs2).subscribe(value => console.log(value));

在此示例中，merge(obs1, obs2) 用于将两个可观察对象 obs1 和 obs2 合并为一个可观察对象，该可观察对象从两个可观察对象发出值。

10、combineLatest()：

该运算符将多个可观察对象发出的最新值组合到一个数组中。它仅在其中一个源可观察对象发出新值时发出新数组。

import {  combineLatest, timer } from 'rxjs';import {  map } from 'rxjs/operators';const observable1 = timer(0, 1000).pipe(map(x => x + ' seconds'));const observable2 = timer(500, 500).pipe(map(x => x + ' half seconds'));combineLatest([observable1, observable2]).subscribe(combinedValues => {   const [value1, value2] = combinedValues;  console.log(`observable1: ${ value1}, observable2: ${ value2}`);});

在这个例子中，我们使用 timer() 函数创建了两个可观察对象。第一个 observable 每秒发出一个值，第二个 observable 每半秒发出一个值。我们使用 map() 运算符将发出的值转换为字符串。

然后我们将一组可观察对象传递给 combineLatest() 函数，该函数返回一个新的可观察对象，该可观察对象发出一个包含每个源可观察对象发出的最新值的数组。我们订阅这个新的 observable，并在发出新的组合值数组时记录每个源 observable 发出的值。

这段代码的输出看起来像这样：

observable1: 0 seconds, observable2: 0.5 half secondsobservable1: 1 seconds, observable2: 1 half secondsobservable1: 2 seconds, observable2: 1.5 half secondsobservable1: 3 seconds, observable2: 2 half secondsobservable1: 4 seconds, observable2: 2.5 half seconds

如您所见，只要其中一个源可观察对象发出新值， combineLatest() 运算符就会发出一个新的组合值数组。

在这种情况下，第一个 observable 每秒发出一个新值，第二个 observable 每半秒发出一个新值，因此组合的 observable 每半秒发出一个新值。

责任编辑：华轩 来源： web前端开发 Angular开发RxJS

(责任编辑：热点)