Rxjs:Observable.First 与 Single 与 Filter 之间的区别

Question

我正在探索 RxJS 库，并且非常喜欢使用 Observable 而不是 Promise。但是，有人可以提供有关使用之间区别的任何详细信息

Observable.First

Observable.Single

以仅返回单个项目的方式应用过滤器

这个库中对 Single 的具体需求是什么？

Answer 1

如果通过过滤器，您的意思是:

let emitted = false;
obs = obs.filter(x => {
  if(emitted) {
    return false;
  } else {
    emitted = true;
    return true;
  }
});

过滤器 (在这种特殊情况下，请检查上面的代码)

将在第一项出现后立即发出。
将忽略所有后续项目。
当源 observable 完成时将完成。

in : -1-2-3--|---
out: -1------|---

第一

将在第一项出现后立即发出。
之后马上完成。

in : -1-2-3--|---
out: -1|----------

单例

如果源 observable 发出多个事件，则会失败。

in : -1-2-3--|---
out: -1-X---------

当源 observable 完成时将发射(并且 single 可以确定不会再发射任何东西)。之后马上完成。

in : -1------|---
out: --------1|--