Таймер
создать Observable, который излучает конкретный элемент через заданный интервал времени
Оператор Timer создает Observable, который излучает один конкретный элемент через заданный промежуток времени.
См. также
Информация, специфичная для языка
RxGroovy timer
RxGroovy реализует этот оператор как timer.
timer возвращает Observable, который излучает одно число ноль после заданного периода задержки.
timer по умолчанию работает с computation Планировщиком, или вы можете переопределить это, передав планировщик в качестве последнего параметра.
- Javadoc:
timer(long,TimeUnit) - Javadoc:
timer(long,TimeUnit,Scheduler)
RxJava 1․x timer
RxJava реализует этот оператор как timer.
timer возвращает Observable, который излучает одно число ноль после заданного периода задержки.
timer по умолчанию работает с computation Планировщиком, или вы можете переопределить это, передав планировщик в качестве последнего параметра.
- Javadoc:
timer(long,TimeUnit) - Javadoc:
timer(long,TimeUnit,Scheduler)
RxJS timer
В RxJS есть две версии оператора timer.
Первая версия оператора timer возвращает Observable, который излучает один элемент после заданного периода задержки. Задавать задержку можно либо как объект Date (то есть, задержка до абсолютного момента), либо как целое число (то есть, задержка на заданное количество миллисекунд).
Также существует версия оператора timer, которая возвращает Observable, излучающий один элемент после заданной задержки, а затем периодически излучающий элементы с заданной периодичностью. Таким образом, он ведет себя немного как оператор Interval.
Пример кода
var source = Rx.Observable.timer(200, 100)
.timeInterval()
.pluck('interval')
.take(3);
var subscription = source.subscribe(
function (x) {
console.log('Next: ' + x);
},
function (err) {
console.log('Error: ' + err);
},
function () {
console.log('Completed');
});
Next: 200 Next: 100 Next: 100 Completed
timer по умолчанию работает с timeout Планировщиком, или вы можете переопределить это, передав планировщик в качестве последнего параметра.
Оператор timer доступен в следующих дистрибутивах:
rx.all.jsrx.all.compat.js-
rx.time.js(требуется либоrx.js, либоrx.compat.js) rx.lite.jsrx.lite.compat.js
RxPHP timer
RxPHP реализует этот оператор как timer.
Возвращает последовательность Observable, которая генерирует значение после истечения срока dueTime.
Пример кода
//from https://github.com/ReactiveX/RxPHP/blob/master/demo/timer/timer.php $source = \Rx\Observable::timer(200); $source->subscribe($createStdoutObserver());
Next value: 0 Complete!
© ReactiveX contributors
Licensed under the Apache License 2.0.
http://reactivex.io/documentation/operators/timer.html
