public function(id: number) {
this.periodicCheckTimer = Observable.timer(10000, 5000).subscribe(
() => {
let model = this.find(id);
if (model['isActivated']) {
this.periodicCheckTimer.unsubscribe();
}
});
}
如果不满足(model ['iSactivated'])不满足,我想在5分钟后自动停止计时器。但是,如果条件满足,我可以手动停止它。在这种情况下,不确定手动停止是否仍然正确。
也赞赏使用其他计时器功能的任何建议。
我没有测试,但这是您提案的替代方法,在5mn之后停止:
function (id: number) {
// emit a value after 5mn
const stopTimer$ = Observable.timer(5 * 60 * 1000);
Observable
// after 10s, tick every 5s
.timer(10000, 5000)
// stop this observable chain if stopTimer$ emits a value
.takeUntil(stopTimer$)
// select the model
.map(_ => this.find(id))
// do not go further unless the model has a property 'isActivated' truthy
.filter(model => model['isActivated'])
// only take one value so we don't need to manually unsubscribe
.first()
.subscribe();
}