Rx.Observable.repeat(value, [repeatCount], [scheduler])
使用指定的调度程序发送观察者消息,生成一个按给定的次数重复给定元素的可观察序列
参数
value
(Any
): 重复的元素.[repeatCount=-1]
(Number
): 重复元素的次数,如果没有指定,则无限重复[scheduler=Rx.Scheduler.immediate]
(Scheduler
): 生产者循环的调度程序,如果没有指定,默认为Scheduler.immediate
.
返回值
(Observable
): 按给定的次数重复给定元素的可观察序列
例
var source = Rx.Observable.repeat(42, 3);
var subscription = source.subscribe(
function (x) {
console.log('Next: ' + x);
},
function (err) {
console.log('Error: ' + err);
},
function () {
console.log('Completed');
});
//=> Next: 42
// => Next: 42
// => Next: 42
// => Completed