如何将 Fs2 中的块流转换为常规流

问题描述 投票:0回答:2

例如:

chunked = Stream(1, 2, 3).chunks
val regular = ???

谢谢你。

scala fs2
2个回答
5
投票

好的,我找到了这里

val regular = chunked.flatMap(c => Stream.chunk(c))


0
投票

提出问题时它可能不存在,但在最新版本的

fs2
中,有一个组合器可以实现这一点:

val regular = chunked.unchunks
© www.soinside.com 2019 - 2024. All rights reserved.