RxJS: oneInTime

Rx.Observable.prototype.oneInTime = function (delay) {
    return this
        .take(1)
        .merge(Rx.Observable.empty().delay(delay))
        .repeat();
};

необходимые модули:

rx.js
rx.binding.js
rx.time.js

Добавить комментарий

Заполните поля или щелкните по значку, чтобы оставить свой комментарий:

Логотип WordPress.com

Для комментария используется ваша учётная запись WordPress.com. Выход /  Изменить )

Google photo

Для комментария используется ваша учётная запись Google. Выход /  Изменить )

Фотография Twitter

Для комментария используется ваша учётная запись Twitter. Выход /  Изменить )

Фотография Facebook

Для комментария используется ваша учётная запись Facebook. Выход /  Изменить )

Connecting to %s