scala - 如何将 Stream[IO, List[A]] 转换为 Stream[IO, A]

Question

我想解析一个输出集合的 json 文件A。的签名Output是IO[List[A]]

如何将此值转换为Stream: Stream[IO, A]？我可以转换为 aStream[IO, List[A]]但这不是我想要的

fs2.Stream.eval(input).flatMap(x => fs2.Stream.apply(x)) 谢谢

score 11 · Accepted Answer

您也可以使用Stream.emits, 它接受一个Seq, 所以fs2.Stream.eval(output).flatMap(fs2.Stream.emits(_))。

这比在 apply 中使用 varargs 更有效，因为它避免了对序列结构的包装和展开——这在专门的原始集合的情况下可以节省很多。

score 4 · Accepted Answer

尝试

fs2.Stream.eval(output).flatMap(x => fs2.Stream.apply(x: _*))

2 回答 2