创建一次性订阅

Question

我需要创建对可观察的订阅，该订阅在第一次调用时立即被处理掉。

有没有像这样的东西：

observable.subscribeOnce(func);

我的用例是，我正在一个快速路由处理程序中创建一个订阅，每个请求都会多次调用该订阅。

Answer 1

更新（2021 12月）：

由于toPromise（）函数在RxJS 7中已被弃用，因此已宣布使用新函数代替它。第一个值从和最后一个值从。

firsValueFrom函数解析第一个发出的值并直接取消订阅资源。当Observable完成而不发出任何值时，它会以EmptyError拒绝。

另一方面，lastValuefrom函数在一定程度上与toPromise（）相同，因为它解析了可观察对象完成时发出的最后一个值。但是，如果可观察对象没有发出任何值，它将拒绝并返回一个空错误。不像toPromise（）在没有值发出时解析未定义。

有关更多信息，请查看文档。

老回答:

如果您只想调用一次可观察对象，这意味着您不会等待来自它的流。因此，在您的情况下，使用 toPromise（） 而不是 subscribe（） 就足够了，因为 toPromise（） 不需要取消订阅。

Answer 2

RxJS有一些我见过的最好的留档。按照下面的链接，您将看到一个非常有用的将用例映射到运算符的表。例如，在“我想取第一个值”用例下有三个运算符：第一个、第一个Or默认和示例。

请注意，如果一个可观察序列在没有通知的情况下完成，那么< code>first操作符会通知订户一个错误，而< code>firstOrDefault操作符会向订户提供一个默认值。

操作员用例查找

Answer 3

不是100%确定您需要什么，但如果您只想观察第一个值，请使用first（）或take（1）：

observable.first().subscribe(func);

注意：.采取（1）和. First（）都在满足条件时自动取消订阅

来自编码器的评论。

import { first } from 'rxjs/operators'
    
observable
  .pipe(first())
  .subscribe(func);

这就是原因