-
- 简介
- 版权
- 基础导航
- 进阶导航
创建操作符
- ajax
- from
- interval
- of
- timer
组合操作符
- combineAll
- combineLatest
- concat
- forkJoin
- merge
- zip
判断操作符
- iif
异常处理
- catchError
- retry
- retryWhen
过滤操作符
- take
转化操作符
- concatMap
- expand
- map
- mergeMap
- reduce
- scan
实用工具
- delay
- delayWhen
- onErrorResumeNext
- repeat
- tap
- timeout
进阶
- delayRetry
- tapAsync
- RxPromise
- rxdis
项目中使用
- Pagination 分页
- Testing 测试
- Nest.js
- Mongoose
- undo
More
repeat
repeat<T>(count: number = Infinity): MonoTypeOperatorFunction<T>
参数
参数 | 说明 |
---|---|
count | 可选,默认值为:Infinity |
返回
类型: MonoTypeOperatorFunction<T>:
示例
简单示例
import { of } from 'rxjs';
import { repeat } from 'rxjs/operators';
const source = of('Repeat message');
const example = source.pipe(repeat(3));
example.subscribe(x => console.log(x));
// 输出:
// Repeat message
// Repeat message
// Repeat message
组合示例
import { interval } from 'rxjs';
import { repeat, take } from 'rxjs/operators';
const source = interval(1000);
const example = source.pipe(take(3), repeat(2));
example.subscribe(x => console.log(x));
// 每秒输出:
// 0
// 1
// 2
// 0
// 1
// 2
源码
https://github.com/ReactiveX/rxjs/blob/master/src/internal/operators/repeat.ts