我的AlertService有
private subject = new Subject< Alert>();.
我希望在5秒后以高压方式清除警报.我可以像这样使用setTimeout()来做到这一点：
private subject = new Subject< Alert>();.
我希望在5秒后以高压方式清除警报.我可以像这样使用setTimeout()来做到这一点：
autoClear(alertId?: string) {
setTimeout(
() => this.subject.next(new Alert({alertId})),5000);
}
我试着做得更优雅,我创建了这段代码：
autoClear(alertId?: string) {
const delay = new Observable(x => {
x.next();
}).delay(5000).subscribe(() => {
this.subject.next(new Alert({alertId}));
delay.unsubscribe();
});
}
两个示例都有效,但它看起来不像是使用RxJS的正确方法.我怎样才能改进它？
解决方法
new Observable(x => {
x.next();
}).delay(5000);
是正确的方法.管道操作符的新方式是
new Observable(x => {
x.next();
}).pipe(delay(5000));
