angular – 如何延迟主题的下一个(值)？

2019年7月28日 169次阅读

我的AlertService有

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));
点赞