TimeInterval
преобразовать Observable, испускающий элементы, в Observable, испускающий показания о времени, прошедшем между этими испусканиями
Оператор TimeInterval перехватывает элементы из источника Observable и вместо них испускает объекты, указывающие время, прошедшее между парами испусканий.
См. также
Сведения, специфичные для языка
RxGroovy timeInterval
Оператор timeInterval преобразует источник Observable в Observable, который испускает показания о времени, прошедшем между последовательными испусканиями источника Observable. Первое испускание из этого нового Observable указывает время, прошедшее между моментом подписки наблюдателя на Observable и моментом, когда источник Observable испустил свой первый элемент. Нет соответствующего испускания, обозначающего время, прошедшее между последним испусканием источника Observable и последующим вызовом onCompleted.
Оператор timeInterval по умолчанию работает с immediate Scheduler, но также есть вариант, позволяющий указать Scheduler, передав его в качестве параметра.
- Javadoc:
timeInterval() - Javadoc:
timeInterval(Scheduler)
RxJava 1․x timeInterval
Оператор timeInterval преобразует источник Observable в Observable, который испускает показания о времени, прошедшем между последовательными испусканиями источника Observable. Первое испускание из этого нового Observable указывает время, прошедшее между моментом подписки наблюдателя на Observable и моментом, когда источник Observable испустил свой первый элемент. Нет соответствующего испускания, обозначающего время, прошедшее между последним испусканием источника Observable и последующим вызовом onCompleted.
Оператор timeInterval по умолчанию работает с immediate Scheduler, но также есть вариант, позволяющий указать Scheduler, передав его в качестве параметра.
- Javadoc:
timeInterval() - Javadoc:
timeInterval(Scheduler)
RxJS timeInterval
Оператор timeInterval преобразует источник Observable в Observable, который испускает показания о времени, прошедшем между последовательными испусканиями источника Observable. Первое испускание из этого нового Observable указывает время, прошедшее между моментом подписки наблюдателя на Observable и моментом, когда источник Observable испустил свой первый элемент. Нет соответствующего испускания, обозначающего время, прошедшее между последним испусканием источника Observable и последующим вызовом onCompleted.
Пример кода
var source = Rx.Observable.timer(0, 1000)
.timeInterval()
.map(function (x) { return x.value + ':' + x.interval; })
.take(5);
var subscription = source.subscribe(
function (x) { console.log('Next: ' + x); },
function (err) { console.log('Error: ' + err); },
function () { console.log('Completed'); }); Next: 0:0 Next: 1:1000 Next: 2:1000 Next: 3:1000 Next: 4:1000 Completed
Оператор timeInterval по умолчанию работает с timeout Scheduler, но также есть вариант, позволяющий указать Scheduler, передав его в качестве параметра.
Оператор timeInterval доступен в каждом из следующих дистрибутивов:
rx.all.jsrx.all.compat.js-
rx.time.js(требуетсяrx.jsилиrx.compat.js) rx.lite.jsrx.lite.compat.js
© ReactiveX contributors
Licensed under the Apache License 2.0.
http://reactivex.io/documentation/operators/timeinterval.html
