RxJS 是一个非常流行的 JavaScript 库，它提供了一种响应式编程的方式，可以方便地处理异步事件流。其中，repeat 方法是一个非常有用的方法，可以让我们重复执行一个 Observable。
repeat 方法的基本用法
repeat 方法可以让我们重复执行一个 Observable。它的基本用法如下所示：
observable.repeat(count)
其中，observable 表示要重复执行的 Observable，count 表示要重复执行的次数。如果不传入 count 参数，则表示无限重复执行。
下面是一个简单的示例，演示了如何使用 repeat 方法重复执行一个 Observable：
// javascriptcn.com 代码示例
const { interval } = rxjs;
const observable = interval(1000);
observable
.pipe(
take(5),
repeat(2)
)
.subscribe(value => console.log(value));在这个示例中，我们使用了 interval 方法创建了一个每隔一秒钟发出一个递增的数字的 Observable。然后，我们使用 take 方法只取了前 5 个数字，并使用 repeat 方法将这 5 个数字重复执行了 2 次。最后，我们订阅了这个 Observable，输出了它发出的所有值。
repeat 方法的高级用法
除了基本用法之外，repeat 方法还有一些高级用法，可以让我们更加灵活地控制重复执行的行为。
1. 使用 repeatWhen 方法
repeatWhen 方法可以让我们根据条件来决定是否重复执行一个 Observable。它的使用方式如下所示：
observable.repeatWhen(notifier)
其中，notifier 表示一个函数，它接收一个 Observable，返回一个 Observable。当 notifier 返回的 Observable 发出一个值时，表示要重复执行 observable。
下面是一个示例，演示了如何使用 repeatWhen 方法重复执行一个 Observable：
// javascriptcn.com 代码示例
const { interval, fromEvent } = rxjs;
const { takeUntil } = rxjs.operators;
const button = document.querySelector('button');
const observable = interval(1000);
const notifier = () => fromEvent(button, 'click');
observable
.pipe(
takeUntil(notifier()),
repeatWhen(notifier)
)
.subscribe(value => console.log(value));在这个示例中，我们使用 interval 方法创建了一个每隔一秒钟发出一个递增的数字的 Observable。然后，我们使用 takeUntil 方法创建了一个 Observable，它会在用户点击按钮时发出一个值，表示要停止执行原来的 Observable。最后，我们使用 repeatWhen 方法将这个 Observable 重复执行，并根据用户点击按钮的情况来决定是否重复执行。
2. 使用 retry 方法
retry 方法可以让我们在发生错误时重试执行一个 Observable。它的使用方式如下所示：
observable.retry(count)
其中，count 表示要重试执行的次数。如果不传入 count 参数，则表示无限重试执行。
下面是一个示例，演示了如何使用 retry 方法在发生错误时重试执行一个 Observable：
// javascriptcn.com 代码示例
const { interval } = rxjs;
const observable = interval(1000);
observable
.pipe(
map(value => {
if (value === 3) {
throw new Error('oops');
}
return value;
}),
retry(2)
)
.subscribe(value => console.log(value));在这个示例中，我们使用 interval 方法创建了一个每隔一秒钟发出一个递增的数字的 Observable。然后，我们使用 map 方法将数字 3 转换成了一个错误，表示发生了错误。最后，我们使用 retry 方法将这个 Observable 重试执行了 2 次，并在控制台输出了它发出的所有值。
总结
RxJS 中的 repeat 方法是一个非常有用的方法，可以让我们重复执行一个 Observable。它不仅支持基本用法，还支持高级用法，可以让我们更加灵活地控制重复执行的行为。在实际开发中，我们可以根据具体的需求来选择不同的用法，以达到最佳的效果。
来源：JavaScript中文网 ，转载请注明来源 本文地址：https://www.javascriptcn.com/post/657e5233d2f5e1655d928851