从ngrx 同步的可观察到的？答案

【问题标题】：is observable take from ngrx synchronous?从ngrx 同步的可观察到的？
【发布时间】：2019-11-04 04:42:22
【问题描述】：

我有以下功能：

从我的商店取值 => 将其转换为 csv => 创建下载链接

  downloadCSV() {
    let href;
    this.store$.select(MissionsStoreSelectors.selectedRoute).pipe(take(1)).subscribe((route) => {
      if (route) {
        const csv = this.csvManipulatorService.generateCSVFromJSON({filename: route.routeId, data: route.waypoints, columns : ['id', 'position', 'rotation']});
        href = this.domSanitizer.bypassSecurityTrustUrl('data:text/csv,' + encodeURIComponent(csv));
      }
    });
    return href;
  }

（不要在意没有守卫的事实，是简化的）

我认为订阅不是同步的。但从这个公认的答案：

How to get current value of State object with @ngrx/store?

好像不是。

我的问题是这会在 100% 的时间里起作用吗？订阅是否总是同步的？

【问题讨论】：

所有的 observables（任何你可以订阅的）都应该被认为不是同步的。但是您始终可以将 observable 转换为 promise 并将您的函数更改为异步函数。如果您尽可能快地只需要一个值（null 或已定义），那么这是一种可靠的方法
旁注：使用可管道select 运算符是自 6.1.0 以来的首选方法。

标签： angular typescript rxjs ngrx

【解决方案1】：

两个答案

没有。使用 take 订阅并不总是同步的。使可观察的异步/同步成为可观察的异步/同步的是发出值的生产者，而不是流中的运算符。现在，如果你在某个时候没有使用take(1) 或取消订阅 Observable，这不是你会遇到的同步问题，而是内存泄漏。 take(1) 很重要，但不是因为同步问题。

同步

这可以通过创建一个简单的同步 Observable、修改一个值然后立即将其注销来进行测试。

https://stackblitz.com/edit/rxjs-ujs6u9

但是你可以简化这个并且返回 Observable 本身而不是把它包装在一个函数中：

csvHref$ = this.store$.select(MissionsStoreSelectors.selectedRoute).pipe(
  take(1),
  map(route => {
    if (!route) {
      return null;
    }

    const csv = this.csvManipulatorService.generateCSVFromJSON({
      filename: route.routeId,
      data: route.waypoints,
      columns : ['id', 'position', 'rotation']
    });

    return this.domSanitizer.bypassSecurityTrustUrl(`data:text/csv,${encodeURIComponent(csv)}`);
  })
)

然后，您无需像函数一样调用它，只需订阅它即可获取值。

csvHref$.subscribe(href => doSomethingWithHref(href));

根据您的使用情况，这可能是不可能的，但您应该将 Observables 视为已经是函数。

【讨论】：

你的第二点听起来不对。作为 Subject 的 observable 不会使订阅和获取第一个值成为同步操作。 ReplaySubject 甚至不是这样。不过，对于 BehaviorSubject 来说确实如此。
还有一点：BehaviorSubject 有一个实际同步的 getValue 方法。如果你想要一个同步值，你应该使用它。如果库将其公开为 Observable 而不是 BehaviorSubject，那么无论如何您都将依赖实现细节（您不应该）而不是合同。
@IngoBürk 你关于 BehaviorSubject 的观点是正确的。但是，ngrx circa 2.0 删除了他们的 value 实现。相反，它们保证订阅商店将始终同步返回当前状态。
好的，如果库明确指出，那么依赖它也是“好的”。仍然感觉有点脏，但如果可能的话，我会避免它。
NgRx 感觉有点脏。