问题标签 [scalaz-stream]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
83 问题
0
投票
1
回答
715
浏览
scala - FS2 按顺序运行流
我有一个相当简单的用例。我有两个 Web 服务调用，一个获取产品，另一个获取关系。我想运行 fetchProducts() 首先从产品集中提取一个字段，然后将输出传递给 fetchRelationships(ids: Seq[String]) 以便我可以在产品上重新设置关系。这是代码：
我受到外部 Api 的限制，无法批量获取结果。所以我不确定如何使用 fs2 来表达这一点，或者我是否应该使用它。
0
投票
1
回答
702
浏览
scala - scala fs2流中的理想块在生产中获得性能提升
想知道scala fs2流中块大小的增加是否会带来性能提升？
0
投票
2
回答
192
浏览
scala - Scala ZIO Stream——将 Stream[A] 转换为 Stream[B]，其中一个 A 产生零个或多个 B
我有一个Stream[A]和一个zeroOrMoreB(value: A): Seq[B]给定A返回零或更多的函数B。从这两部分，我如何构造一个Stream[B]？
我可以得到一个Stream[Stream[B]]（见下文），但我不知道如何把它弄平。