rxjs - 为什么某些RxJS 6运算符采用谓词和投影/选择器？

Question

Closed. This question is opinion-based。它当前不接受答案。












想改善这个问题吗？更新问题，以便 editing this post用事实和引用来回答。

去年关闭。



Improve this question




这是有关RxJS 6设计的问题。以两个运算符为例。

combineLatest 将投影或选择器(在文档的不同区域中以不同的名称调用)作为可选参数，即将输入可观察值的值映射为将返回的可观察值的值类型的函数。
大概combineLatest([as, bs], f)与combineLatest([as, bs]).pipe(map(f))相同。

last 将一个谓词用作(可选)参数，该谓词可用于从可观察的源中过滤值。
大概source.pipe(last(p))与source.pipe(filter(p), last())相同。 ^ 1

考虑到这些等效性，为什么还要附加选择器和投影呢？以这种方式违反单一责任原则有什么好处？
^ 1:或者差不多； last将可观察到的源传递给谓词，但 filter却不传递。大多数谓词不需要该参数，而少数谓词可以使用某些管道体操:

source.pipe(src => {
  const p2 = (value, index) => p(value, index, src)
  return filter(p2)(src)
})

最佳答案

有很多人参与Rxjs V6 API设计。他们可以补充这个答案。

我的猜测是combineLatest([as, bs], f)比combineLatest([as, bs]).pipe(map(f))具有性能优势。至少这是Rxjs v4中的基本原理。 v6中可能仍然如此。 pipe通过直接传递谓词来引入您没有的间接级别，这可能会导致性能降低。同样，obs.pipe(f,g)的性能应低于obs.pipe(x => g(f(x)))。像往常一样，在性能方面，测量就是一切，这将是您在完成其他所有工作后想要进行的微优化。

关于rxjs - 为什么某些RxJS 6运算符采用谓词和投影/选择器？ ，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/55092477/

上一篇：android - MediaHTTPConnection : readAt 1343667/32768 => java.net.ProtocolException

下一篇：php - Symfony 4 未登录生产模式

相关文章：

javascript - Angular 2 中用于双向数据绑定(bind)的共享 RxJS 主题

typescript - RXJS Angular-使用.subscribe和Observable处理错误

javascript - 如何使用 RxJS 显示一个 "user is typing"指标？

Angular 服务不适用于 http.get observable

angular - 发送 :false 时测试@Effect

Angular - http 拦截器 - http 速率限制器 - 滑动窗口

reactive-programming - RxJS - 如何将 toArray() 与异步 observables 数组一起使用？

javascript - 为项目列表正确声明 Observable

angular - 类型 'map' 上不存在属性 'Subject<{}>'

javascript - RxJS 和 React 的 setState - 延迟函数执行直到订阅

Answer 1

有很多人参与Rxjs V6 API设计。他们可以补充这个答案。

我的猜测是combineLatest([as, bs], f)比combineLatest([as, bs]).pipe(map(f))具有性能优势。至少这是Rxjs v4中的基本原理。 v6中可能仍然如此。 pipe通过直接传递谓词来引入您没有的间接级别，这可能会导致性能降低。同样，obs.pipe(f,g)的性能应低于obs.pipe(x => g(f(x)))。像往常一样，在性能方面，测量就是一切，这将是您在完成其他所有工作后想要进行的微优化。