rxjs - RxJS - toBlocking 操作符

Question

在 RxJava 中有 Observable.toBlocking() 操作符来同步检索 observable 的数据。我找不到 RxJS 的类似运算符。我想使用这个操作符来改进我的 Rx 代码，而不是使用另一个函数式编程库......

Answer 1

见调度器

如果你不提供调度器，RxJS 会根据最小并发的原则选择一个默认的调度器。这意味着选择引入满足操作员需求的最少并发量的调度程序。

只要您不指定调度程序，RxJS 本身就会选择一个阻塞调度程序/同步解析 observable（立即调度程序），正如您在这个jsbin中看到的那样- 第一个 observable 在第二个 observable 启动之前完成。

如果要显式控制并发级别，可以通过将特定调度程序传递给支持此选项的操作员来实现。