订阅 rxjs 中的超时

Question

我有以下代码

this.someFormGroup.controls['control1'].valueChanges.subscribe(val => {
   if (val) {
      doStuff();
   }
   setTimeout(() => doOtherStuff(), 1000);
});

我想知道是否有另一种方法可以在不使用 setTimeout 的情况下实现这一点，我正在考虑来自 rxjs 的 timer，但我不确定如何将其合并到这里。

Answer 1

尽管上述解决方案有效，但管道副作用绝不是您想要的解决方案。 Rx 的一大优势是您始终知道发生了什么、何时以及如何。有很多文章介绍了为什么一般不应该使用副作用：

• Coding style - Why is using side effects bad practice in JavaScript constructors?
• when should we use the rxjs tap operator。

另外请记住：在没有点击的情况下实施解决方案总是，真的总是可能的，而且大多数时候你可以看到它很容易。

private readonly valueChanges$: Observable<any> = this.someFormGroup.controls['control1'].valueChanges

private readonly delayedValuechanges$: Observable<any> = this.valueChanges$.pipe(
  delay(1000)
)

constructor(private readonly someFormGroup: SomeFormGroup) {
  this.valueChanges$.subscribe(this.doStuff);
  this.delayedValueChanges$.subscribe(this.doOtherStuff);
}

Answer 2

您可以使用tap 和delay：

this.someFormGroup.controls['control1'].valueChanges
  .pipe(
    tap(val => {
      if (val) {
        doStuff();
      }
    }),
    delay(1000),
  )
  .subscribe(() => doOtherStuff());