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