使用rxjs进行分组和聚合
使用rxjs进行分组和聚合
提问于 2015-07-30 09:03:27
扫描的工作方式如下(使用求和函数)：
1-1-1-1-1-1 -> 1-2-3-4-5-6但我需要这样的东西:用n=3
1-1-1-1-1-1 -> 3-3我如何实现这种行为？
回答 2
Stack Overflow用户
回答已采纳
发布于 2015-07-30 15:44:11
在RxJ中，您可以使用bufferWithCount
var source = Rx.Observable.from([1,1,1,1,1,1])
.bufferWithCount(3)
.flatMap(group => Rx.Observable.from(group).sum());您可以选择使用windowWithCount，这样就不必为了使用sum而重新包装输出，但也可以获得一个空的最终窗口，这将触发一个无关的0值。
Stack Overflow用户
发布于 2015-07-30 09:34:33
这在c#中是可行的：
var query =
new [] { 1, 1, 1, 1, 1, 1, }
.ToObservable()
.Buffer(3)
.Select(x => x.Sum());我认为rxjs也会起类似的作用。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/31719467
复制相关文章
相似问题
腾讯云开发者
