rxjs - 创建一次性订阅

Question

我需要创建一个对 Observable 的订阅，该订阅在首次调用时会立即释放。

有没有类似的东西:

observable.subscribeOnce(func);

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

Answer 1

不能 100% 确定您需要什么，但如果您只想观察第一个值，请使用 first() 或 take(1):

observable.first().subscribe(func);

注意:.take(1) 和 .first() 满足条件时都会自动取消订阅

从 RxJS 5.5+ 更新

摘自 Coderer 的评论.

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

Here's why