使用Rxjs管道如何知道何时可观察完成？

Question

在角度分量的顶部有以下初始化。

public myDataObservable$: Observable<MyData[]>;

在我的组件中的某个地方，我使用选择器对Ngrx存储进行以下调用，以获取可观测数据。所有这些都很好，我得到了我想要的数据。

this.myDataObservable$ = this.store.pipe(select(MyDataStore.getMyData));

我需要知道这个可观察的什么时候完成。我需要设置一个布尔值，当所有可观察到的数据都试图完成时，它将关闭加载指示器。这是通过Web服务完成的。

因为可观测的源来自其他地方，所以我无法挂起“完整”回调（）=

我尝试过各种Rxjs操作符，如TakeTo和Finize，但运气不佳。这些操作员会立即被呼叫，我的装载指示器会以上升的速度关闭。

我浏览了互联网，尝试了许多不同的解决方案，但我找不到答案。谢谢你花时间看这个。




Answer 1

解决方案是将加载指示器的布尔值置于状态，并将其设置在减速器中。当数据填充时，将调用加载缩减器，并且状态布尔值设置为true。调用loading success reducer时，状态布尔值将变为false。

之后，我创建了一个选择器来获取布尔状态。

我现在将其初始化为一个可观察的布尔值，在我的ngOnInit方法中，我可以声明以下内容：，

this.showLoading$ = this.store.pipe(select(TechnopediaStore.getisLoadingData));

因此，我只需将其应用于我的代码中的structure指令。html和它的工作非常完美。

Answer 2

我不是100%确定你想要什么；但是为什么下面的代码不起作用呢？我不知道您正在使用哪种类型的存储（ngxs、ngrx、？）。存储中可能有一个属性，用于在调用时设置加载指示器。然后，当它成功返回或出现错误时，可以再次以状态更新它。

this.myDataObservable$ = this.store.pipe(select(MyDataStore.getMyData));

this.myDataObservable$.subscribe(
  next: x => console.log('Observer got a next value: ' + x),
  error: err => console.error('Observer got an error: ' + err),
  complete: () => this.loadingIndicator = false),
);