如何将流[IO，List[A]]转换为流[IO，A]

Question

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

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

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

Answer 1

试一试

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

(colon underscore star) do in Scala?

Answer 2

您还可以使用Stream.emits，它接受Seq，所以使用fs2.Stream.eval(output).flatMap(fs2.Stream.emits(_))。

这比在apply中使用varargs更有效，因为它避免了对序列结构的包装和展开--对于专用的原语集合来说，这可以节省很多。