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

Question

我的 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 的正确方法。我该如何改进它？

Answer 1

new Observable(x => {
  x.next();
}).delay(5000);

是正确的方法。管道运算符的新方法是

new Observable(x => {
  x.next();
}).pipe(delay(5000));