RxJS 是一种基于观察者模式的响应式编程库，它提供了一些强大的操作符来帮助我们处理异步数据流。其中一个非常有用的操作符是 repeat，它可以让我们重复执行一个 Observable 序列。
repeat 操作符的语法
repeat 操作符的语法如下：
repeat(count?: number): Observable
其中 count 是可选参数，表示要重复执行的次数。如果不传递 count，则表示无限重复执行。
repeat 操作符的实际应用
repeat 操作符的实际应用非常广泛，比如：
1. 重复执行一个 HTTP 请求
有时候我们需要重复执行一个 HTTP 请求，直到它返回我们想要的数据。这时候就可以使用 repeat 操作符。例如：
// javascriptcn.com 代码示例
import { from } from 'rxjs';
import { mergeMap, repeat } from 'rxjs/operators';
import { HttpClient } from '@angular/common/http';
const url = 'https://api.github.com/users/octocat';
const http$ = from(fetch(url));
http$.pipe(
mergeMap(res => res.json()),
repeat(3) // 重复执行 3 次
).subscribe(
data => console.log(data),
error => console.error(error),
() => console.log('completed')
);上面的代码中，我们使用了 fetch 函数来发送一个 HTTP 请求，并将其转换为一个 Observable。然后我们使用 mergeMap 操作符将响应对象转换为 JSON 数据。最后，我们使用 repeat 操作符重复执行 3 次，直到我们得到我们想要的数据。
2. 重复执行一个动画
有时候我们需要重复执行一个动画，比如一个旋转的 Loading 图标。这时候也可以使用 repeat 操作符。例如：
// javascriptcn.com 代码示例
import { interval } from 'rxjs';
import { repeat, take } from 'rxjs/operators';
const loading$ = interval(1000).pipe(
take(5), // 只执行 5 次
repeat() // 无限重复执行
);
loading$.subscribe(
() => console.log('loading...')
);上面的代码中，我们使用 interval 操作符来创建一个每秒发出一个值的 Observable。然后我们使用 take 操作符只发出 5 个值，表示只执行 5 次动画。最后，我们使用 repeat 操作符无限重复执行。
repeat 操作符的示例代码
下面是一个更完整的示例代码，演示了如何使用 repeat 操作符重复执行一个 HTTP 请求：
// javascriptcn.com 代码示例
import { from } from 'rxjs';
import { mergeMap, repeat } from 'rxjs/operators';
import { HttpClient } from '@angular/common/http';
const url = 'https://api.github.com/users/octocat';
const http$ = from(fetch(url));
http$.pipe(
mergeMap(res => res.json()),
repeat(3) // 重复执行 3 次
).subscribe(
data => console.log(data),
error => console.error(error),
() => console.log('completed')
);总结
repeat 操作符是 RxJS 中非常有用的一个操作符，它可以让我们重复执行一个 Observable 序列。在实际开发中，我们可以使用它来重复执行一个 HTTP 请求、重复执行一个动画等等。希望本文可以帮助大家更好地理解 repeat 操作符的语法和实际应用。
来源：JavaScript中文网 ，转载请注明来源 本文地址：https://www.javascriptcn.com/post/6582ccc5d2f5e1655dddc549