rxjs - 有没有办法在一行中对下一个和错误回调执行 Observables 的副作用？

Question

我想要实现的是执行副作用，例如在可观察对象完成或引发错误时隐藏进度条或加载微调器，但如果可能的话，我只想在一个地方执行此操作。

前任。

当前实施：

myObservable.subscribe(next=>{ 
 stopLoader();
 }, error=>{
 stopLoader();
});

期望的实现：

myObservable
.pipe(<some-unknown-operator-to-me-that-might-exist>(_=> stopLoader()))
.subscribe(......);

标签： rxjs

Answer 1

尝试finalize运算符

myObservable.pipe( ..... , finalize(()=>stopLoader()))