timer
签名: timer(initialDelay: number | Date, period: number, scheduler: Scheduler): Observable
给定持续时间后,再按照指定间隔时间依次发出数字。
示例
示例 1: 当 timer 结束时发出一个值
import { timer } from 'rxjs/observable/timer';
// 1秒后发出0,然后结束,因为没有提供第二个参数
const source = timer(1000);
// 输出: 0
const subscribe = source.subscribe(val => console.log(val));
示例 2: timer 1秒后发出值,然后每2秒发出值
import { timer } from 'rxjs/observable/timer';
/*
timer 接收第二个参数,它决定了发出序列值的频率,在本例中我们在1秒发出第一个值,
然后每2秒发出序列值
*/
const source = timer(1000, 2000);
// 输出: 0,1,2,3,4,5......
const subscribe = source.subscribe(val => console.log(val));
其他资源
- timer - 官方文档
- 创建操作符: interval 和 timer - André Staltz
源码:
https://github.com/ReactiveX/rxjs/blob/master/src/internal/observable/timer.ts