rxjs创build一次订阅configuration方法

我需要创build一个订阅到一个observable当它被第一次调用时立即处理。

有这样的事吗？ 像observable.subscribeOnce（func）

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

Answer 1

不是100％确定你需要什么，但是如果你只想观察第一个值，那么使用first()或者take(1) ：

 observable.first().subscribe(func); 

Answer 2

RxJS有一些我遇到过的最好的文档。 下面的链接将带你到一个非常有用的表映射用例运营商。 例如，在“我要取第一个值”的用例下有三个操作符： first ， firstOrDefault和sample 。

请注意，如果可观察序列完成且没有通知，则第first运算符会向订阅者通知错误，而firstOrDefault运算符会向订阅者提供默认值。

运算符用例查找